- public Future<FcpKeyPair> execute() {
- return threadPool.submit(() -> {
- connect();
- GenerateSSK generateSSK = new GenerateSSK();
- AtomicReference<FcpKeyPair> keyPair = new AtomicReference<>();
- FcpReplySequence replySequence = new FcpReplySequence(threadPool, fcpConnection.get());
- replySequence.handle(SSKKeypair.class)
- .with((message) -> keyPair.set(
- new FcpKeyPair(message.getRequestURI(), message.getInsertURI())));
- replySequence.waitFor(() -> keyPair.get() != null);
- replySequence.send(generateSSK).get();
- return keyPair.get();
- });
+ protected void consumeNodeHello(NodeHello nodeHello) {
+ receivedNodeHello.set(nodeHello);
+ }
+
+ @Override
+ protected void consumeCloseConnectionDuplicateClientName(
+ CloseConnectionDuplicateClientName closeConnectionDuplicateClientName) {
+ receivedClosed.set(true);