}
private FcpConnection establishConnection() throws IOException {
FcpConnection connection = new FcpConnection(hostname, port);
connection.connect();
}
private FcpConnection establishConnection() throws IOException {
FcpConnection connection = new FcpConnection(hostname, port);
connection.connect();
} catch (InterruptedException | ExecutionException e) {
connection.close();
throw new IOException(String.format("Could not connect to %s:%d.", hostname, port), e);
}
} catch (InterruptedException | ExecutionException e) {
connection.close();
throw new IOException(String.format("Could not connect to %s:%d.", hostname, port), e);
}
public ClientHelloReplySequence(FcpConnection connection) {
super(ClientHelloImpl.this.threadPool, connection);
public ClientHelloReplySequence(FcpConnection connection) {
super(ClientHelloImpl.this.threadPool, connection);
- protected void consumeCloseConnectionDuplicateClientName(
- CloseConnectionDuplicateClientName closeConnectionDuplicateClientName) {
- receivedClosed.set(true);
+ protected void consumeNodeHello(NodeHello nodeHello) {
+ receivedNodeHello.set(nodeHello);