From 302f06defdac88f96902672d836aa4fd930af82d Mon Sep 17 00:00:00 2001 From: Ralph Soika Date: Fri, 19 Apr 2019 00:20:23 +0200 Subject: [PATCH] provide consumer example issue #73 --- .../main/java/org/imixs/workflow/kafka/ConsumerService.java | 3 +++ .../src/test/java/org/imixs/workflow/kafka/TestProducer.java | 3 +-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/imixs-adapters-kafka/src/main/java/org/imixs/workflow/kafka/ConsumerService.java b/imixs-adapters-kafka/src/main/java/org/imixs/workflow/kafka/ConsumerService.java index a486a6f..95add15 100644 --- a/imixs-adapters-kafka/src/main/java/org/imixs/workflow/kafka/ConsumerService.java +++ b/imixs-adapters-kafka/src/main/java/org/imixs/workflow/kafka/ConsumerService.java @@ -56,6 +56,9 @@ public class ConsumerService implements Serializable { /** * On startup we just initialize a new Timer running each 10 seconds to poll the * message queue + *

+ * + * @see https://stackoverflow.com/questions/55640112/how-to-implement-a-permanent-background-process-with-ejbs * */ @PostConstruct diff --git a/imixs-adapters-kafka/src/test/java/org/imixs/workflow/kafka/TestProducer.java b/imixs-adapters-kafka/src/test/java/org/imixs/workflow/kafka/TestProducer.java index 93cd8d4..fb5aae9 100644 --- a/imixs-adapters-kafka/src/test/java/org/imixs/workflow/kafka/TestProducer.java +++ b/imixs-adapters-kafka/src/test/java/org/imixs/workflow/kafka/TestProducer.java @@ -4,7 +4,6 @@ import java.util.concurrent.ExecutionException; import java.util.logging.Logger; -import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerConfig; @@ -19,7 +18,7 @@ import junit.framework.Assert; /** - * This test verifies the IBAN regex + * Junit test producing a imixs kafka event * * @author rsoika *