1 files changed, 26 insertions, 0 deletions
diff --git a/src/main/java/at/gv/egiz/moazs/process/SingleNodeResponseHandler.java b/src/main/java/at/gv/egiz/moazs/process/SingleNodeResponseHandler.java
new file mode 100644
index 0000000..ec609cb
--- /dev/null
+++ b/src/main/java/at/gv/egiz/moazs/process/SingleNodeResponseHandler.java
@@ -0,0 +1,26 @@
+package at.gv.egiz.moazs.process;
+
+import at.gv.egiz.moazs.verify.MsgResponseVerifier;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import static java.util.concurrent.CompletableFuture.supplyAsync;
+
+@Component
+public class SingleNodeResponseHandler implements MsgResponseHandler {
+
+    private final MsgResponseVerifier verifier;
+    private final MsgResponseSink sink;
+
+    @Autowired
+    public SingleNodeResponseHandler(MsgResponseVerifier verifier, MsgResponseSink sink) {
+        this.verifier = verifier;
+        this.sink = sink;
+    }
+
+    @Override
+    public void handle(String id) {
+        supplyAsync(() -> verifier.verify(id))
+                .thenAcceptAsync((response) -> sink.handle(response));
+    }
+}