feat: Send error to frontend if produce fails (#23)

katheris · web-flow · commit 8bca8fc68ec2 · 2020-06-24T13:45:37.000+01:00
Signed-off-by: Katherine Stanley &lt;katheris@uk.ibm.com&gt;
diff --git a/src/main/java/kafka/vertx/demo/PeriodicProducer.java b/src/main/java/kafka/vertx/demo/PeriodicProducer.java
@@ -79,6 +79,9 @@ private void produceKafkaRecord(KafkaProducer<String, String> kafkaProducer, Str
           .put("value", payload);
         vertx.eventBus().send(Main.PERIODIC_PRODUCER_BROADCAST, kafkaMetaData);
       })
-      .onFailure(err -> logger.error("Error sending {}", payload, err));
+      .onFailure(err -> {
+        logger.error("Error sending {}", payload, err);
+        vertx.eventBus().send(Main.PERIODIC_PRODUCER_BROADCAST, new JsonObject().put("status", "ERROR"));
+      });
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -79,6 +79,9 @@ private void produceKafkaRecord(KafkaProducer<String, String> kafkaProducer, Str`
`79`	`79`	`.put("value", payload);`
`80`	`80`	`vertx.eventBus().send(Main.PERIODIC_PRODUCER_BROADCAST, kafkaMetaData);`
`81`	`81`	`})`
`82`		`- .onFailure(err -> logger.error("Error sending {}", payload, err));`
	`82`	`+ .onFailure(err -> {`
	`83`	`+ logger.error("Error sending {}", payload, err);`
	`84`	`+ vertx.eventBus().send(Main.PERIODIC_PRODUCER_BROADCAST, new JsonObject().put("status", "ERROR"));`
	`85`	`+ });`
`83`	`86`	`}`
`84`	`87`	`}`