# HG changeset patch
# User unexist
# Date 1627654771 -7200
# Node ID 96011a00be300b30a3239ea39bf992cef2e47c5d
# Parent  a0e15b59e560406d97ebf8e392cd42bd6e5eff30
Updated doc header

diff -r a0e15b59e560 -r 96011a00be30 pom.xml
--- a/pom.xml	Fri Jul 30 13:31:55 2021 +0200
+++ b/pom.xml	Fri Jul 30 16:19:31 2021 +0200
@@ -3,7 +3,6 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
          xmlns="http://maven.apache.org/POM/4.0.0">
     <modelVersion>4.0.0</modelVersion>
-    <groupId>dev.unexist.showcase</groupId>
     <artifactId>showcase-eventbus-quarkus</artifactId>
     <version>0.1</version>
 
@@ -14,8 +13,26 @@
     </parent>
 
     <properties>
+        <smallrye-reactive.version>3.8.0</smallrye-reactive.version>
     </properties>
 
     <dependencies>
+        <!-- Quarkus -->
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-smallrye-reactive-messaging-kafka</artifactId>
+        </dependency>
+
+        <!-- Testing -->
+        <dependency>
+            <groupId>io.smallrye.reactive</groupId>
+            <artifactId>smallrye-reactive-messaging-in-memory</artifactId>
+            <version>${smallrye-reactive.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 </project>
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/adapter/TodoResource.java
--- a/src/main/java/dev/unexist/showcase/todo/adapter/TodoResource.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/adapter/TodoResource.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Todo resource
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/adapter/TodoSink.java
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/main/java/dev/unexist/showcase/todo/adapter/TodoSink.java	Fri Jul 30 16:19:31 2021 +0200
@@ -0,0 +1,47 @@
+/**
+ * @package Quarkus-Kafka-Showcase
+ *
+ * @file Todo sink
+ * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
+ * @version $Id$
+ *
+ * This program can be distributed under the terms of the Apache License v2.0. See the file LICENSE for details.
+ **/
+
+package dev.unexist.showcase.todo.adapter;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import dev.unexist.showcase.todo.domain.todo.TodoBase;
+import dev.unexist.showcase.todo.domain.todo.TodoService;
+import org.eclipse.microprofile.reactive.messaging.Incoming;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
+
+@ApplicationScoped
+public class TodoSink {
+    private static final Logger LOGGER = LoggerFactory.getLogger(TodoSink.class);
+
+    @Inject
+    TodoService todoService;
+
+    private final ObjectMapper mapper = new ObjectMapper();
+
+    @Incoming("todo-sink")
+    public void consumeTodos(String json) {
+        TodoBase todo = null;
+
+        try {
+            todo = this.mapper.readValue(json, TodoBase.class);
+        } catch (JsonProcessingException e) {
+            LOGGER.error("Error reading JSON", e);
+        }
+
+        todoService.create(todo);
+    }
+}
+
+
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/domain/todo/DueDate.java
--- a/src/main/java/dev/unexist/showcase/todo/domain/todo/DueDate.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/domain/todo/DueDate.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file DueDate class
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/domain/todo/Todo.java
--- a/src/main/java/dev/unexist/showcase/todo/domain/todo/Todo.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/domain/todo/Todo.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Todo class and aggregate root
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/domain/todo/TodoBase.java
--- a/src/main/java/dev/unexist/showcase/todo/domain/todo/TodoBase.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/domain/todo/TodoBase.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Todo base class
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/domain/todo/TodoRepository.java
--- a/src/main/java/dev/unexist/showcase/todo/domain/todo/TodoRepository.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/domain/todo/TodoRepository.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Todo repository interface
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/domain/todo/TodoService.java
--- a/src/main/java/dev/unexist/showcase/todo/domain/todo/TodoService.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/domain/todo/TodoService.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Todo service and domain service
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
@@ -13,7 +13,6 @@
 
 import javax.enterprise.context.ApplicationScoped;
 import javax.inject.Inject;
-import javax.inject.Named;
 import java.util.List;
 import java.util.Optional;
 
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/infrastructure/persistence/ListTodoRepository.java
--- a/src/main/java/dev/unexist/showcase/todo/infrastructure/persistence/ListTodoRepository.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/infrastructure/persistence/ListTodoRepository.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Todo repository
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
@@ -17,7 +17,6 @@
 import org.slf4j.LoggerFactory;
 
 import javax.enterprise.context.ApplicationScoped;
-import javax.inject.Named;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
diff -r a0e15b59e560 -r 96011a00be30 src/main/java/dev/unexist/showcase/todo/infrastructure/serializer/DateSerializer.java
--- a/src/main/java/dev/unexist/showcase/todo/infrastructure/serializer/DateSerializer.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/main/java/dev/unexist/showcase/todo/infrastructure/serializer/DateSerializer.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Todo serializer
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>
diff -r a0e15b59e560 -r 96011a00be30 src/test/java/dev/unexist/showcase/todo/application/TodoResourceTest.java
--- a/src/test/java/dev/unexist/showcase/todo/application/TodoResourceTest.java	Fri Jul 30 13:31:55 2021 +0200
+++ b/src/test/java/dev/unexist/showcase/todo/application/TodoResourceTest.java	Fri Jul 30 16:19:31 2021 +0200
@@ -1,5 +1,5 @@
 /**
- * @package Showcase-Microstream-Helidon
+ * @package Showcase-Eventbus-Quarkus
  *
  * @file Stupid integration test
  * @copyright 2020-2021 Christoph Kappel <christoph@unexist.dev>