provide consumer example

issue #73
imixs · Apr 18, 2019 · 302f06d · 302f06d
1 parent 01bcf31
commit 302f06d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 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
@@ -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
+	 * <p>
+	 * 
+	 * @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
@@ -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
  *