X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FGetNodeCommandImpl.java;h=025cddca152d4cfdd9f192139bbc46960a398670;hb=ebede056b159ea34d294f3fac0e2def790454a48;hp=24471797e09d7e3fdaafc16bc4232736fa36f3e2;hpb=b315e585ac78058d727eea98aca2ba9c7ed93c51;p=jFCPlib.git diff --git a/src/main/java/net/pterodactylus/fcp/quelaton/GetNodeCommandImpl.java b/src/main/java/net/pterodactylus/fcp/quelaton/GetNodeCommandImpl.java index 2447179..025cddc 100644 --- a/src/main/java/net/pterodactylus/fcp/quelaton/GetNodeCommandImpl.java +++ b/src/main/java/net/pterodactylus/fcp/quelaton/GetNodeCommandImpl.java @@ -14,7 +14,7 @@ import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; /** - * Default {@link GetNodeCommandImpl} implementation based on {@link FcpReplySequence}. + * Default {@link GetNodeCommandImpl} implementation based on {@link FcpDialog}. * * @author David ‘Bombe’ Roden */ @@ -57,16 +57,16 @@ public class GetNodeCommandImpl implements GetNodeCommand { private NodeData executeSequence() throws InterruptedException, ExecutionException, IOException { GetNode getNode = new GetNode(new RandomIdentifierGenerator().generate(), giveOpennetRef.get(), includePrivate.get(), includeVolatile.get()); - try (GetNodeReplySequence getNodeReplySequence = new GetNodeReplySequence()) { - return getNodeReplySequence.send(getNode).get(); + try (GetNodeDialog getNodeDialog = new GetNodeDialog()) { + return getNodeDialog.send(getNode).get(); } } - private class GetNodeReplySequence extends FcpReplySequence { + private class GetNodeDialog extends FcpDialog { private final AtomicReference nodeData = new AtomicReference<>(); - public GetNodeReplySequence() throws IOException { + public GetNodeDialog() throws IOException { super(threadPool, connectionSupplier.get()); }