From: Kai Moritz <kai@juplo.de>
Date: Thu, 14 Sep 2023 22:58:31 +0000 (+0200)
Subject: WIP:ALIGN
X-Git-Tag: rebase--2023-09-15--10-15~7
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=7e689e05d378121ebb855ce97c21b1902d809380;p=demos%2Fkafka%2Fchat

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 997b5f16..787aec8b 100644
--- 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