Changeset 34:a31355c9e6c9

Removed @Incoming block
author unexist
date Wed, 18 Aug 2021 16:50:35 +0200
parents 121aac3bc615
children d5a8a2f4e912
files services/todo-service-extension/src/main/java/dev/unexist/showcase/todo/adapter/TodoSink.java
diffstat 1 files changed, 0 insertions(+), 12 deletions(-) [+]
line wrap: on
line diff
--- a/services/todo-service-extension/src/main/java/dev/unexist/showcase/todo/adapter/TodoSink.java	Wed Aug 18 16:50:21 2021 +0200
+++ b/services/todo-service-extension/src/main/java/dev/unexist/showcase/todo/adapter/TodoSink.java	Wed Aug 18 16:50:35 2021 +0200
@@ -11,33 +11,21 @@
 
 package dev.unexist.showcase.todo.adapter;
 
-import dev.unexist.showcase.eventsplit.EventSplitDispatcher;
 import io.quarkus.vertx.ConsumeEvent;
 import org.eclipse.microprofile.reactive.messaging.Channel;
 import org.eclipse.microprofile.reactive.messaging.Emitter;
-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
-    EventSplitDispatcher dispatcher;
-
     @Channel("todo_out")
     Emitter<String> emitter;
 
-    @Incoming("todo_in")
-    public void consumeTodo(String message) {
-        LOGGER.info("consumeTodo: message={}, dispatcher={}", message, this.dispatcher);
-    }
-
-
     @ConsumeEvent("todo_in1")
     public void consumeTodoIn1(String message) {
         LOGGER.info("consumeTest1: {}", message);