WIP:ALIGN

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
index 997b5f1..787aec8 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
@@ -51,14 +51,14 @@ public class KafkaServicesConfiguration
   ConsumerTaskExecutor infoChannelConsumerTaskExecutor(
       ThreadPoolTaskExecutor taskExecutor,
       InfoChannel infoChannel,
-      Consumer<String, AbstractMessageTo> dataChannelConsumer,
+      Consumer<String, AbstractMessageTo> infoChannelConsumer,
       ConsumerTaskExecutor.WorkAssignor workAssignor)
   {
     return new ConsumerTaskExecutor(
         taskExecutor,
         infoChannel,
-        dataChannelConsumer,
-        workAssignor);
+        infoChannelConsumer,
+        (consumer) -> { /* No work to assign here */ });
   }
 
   @Bean