private final String hostname;
private final int port;
private final AtomicReference<FcpConnection> fcpConnection = new AtomicReference<>();
private final String hostname;
private final int port;
private final AtomicReference<FcpConnection> fcpConnection = new AtomicReference<>();
public DefaultFcpClient(ExecutorService threadPool, String hostname, int port, Supplier<String> clientName,
Supplier<String> expectedVersion) {
public DefaultFcpClient(ExecutorService threadPool, String hostname, int port, Supplier<String> clientName,
Supplier<String> expectedVersion) {
private class ClientHelloReplySequence extends FcpReplySequence<Void> {
private final AtomicReference<NodeHello> receivedNodeHello;
private class ClientHelloReplySequence extends FcpReplySequence<Void> {
private final AtomicReference<NodeHello> receivedNodeHello;