aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/at/gv/egiz/moazs/process/SingleNodeResponseHandler.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/at/gv/egiz/moazs/process/SingleNodeResponseHandler.java')
-rw-r--r--src/main/java/at/gv/egiz/moazs/process/SingleNodeResponseHandler.java26
1 files changed, 0 insertions, 26 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
deleted file mode 100644
index 65f5eed..0000000
--- a/src/main/java/at/gv/egiz/moazs/process/SingleNodeResponseHandler.java
+++ /dev/null
@@ -1,26 +0,0 @@
-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 responseID) {
- supplyAsync(() -> verifier.verify(responseID))
- .thenAcceptAsync(response -> sink.handle(response));
- }
-}