Vorlage für die JSON-Version des Rest-Producers

[demos/kafka/training] / src / main / java / de / juplo / kafka / RestProducer.java

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index 4be2dcd..2e0da97 100644 (file)
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -30,13 +30,9 @@ public class RestProducer
       @RequestHeader(name = "X-id", required = false) Long correlationId,
       @RequestBody Integer number)
   {
-    ResultRecorder result = new ResultRecorder(number+1);
+    ResultRecorder result = new ResultRecorder(1);
 
-    for (int i = 1; i <= number; i++)
-    {
-      send(key, new AddNumberMessage(number, i), correlationId, result);
-    }
-    send(key, new CalculateSumMessage(number), correlationId, result);
+    send(key, number, correlationId, result);
 
     return result.getDeferredResult();
   }