Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
private static class TestAsyncConnectionFactory implements AsyncConnectionFactory {
@Override
public AsyncConnection create(final ServerAddress serverAddress) {
return new AsyncConnection() {
@Override
public void sendMessage(final List<ByteBuf> byteBuffers, final SingleResultCallback<Void> callback) {
throw new UnsupportedOperationException();
}
@Override
public void receiveMessage(final ResponseSettings responseSettings, final SingleResultCallback<ResponseBuffers> callback) {
throw new UnsupportedOperationException();
}
@Override
public void close() {
}
@Override
public boolean isClosed() {
throw new UnsupportedOperationException();
}
@Override
public ServerAddress getServerAddress() {
throw new UnsupportedOperationException();
}
};
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment