From 7e689e05d378121ebb855ce97c21b1902d809380 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 15 Sep 2023 00:58:31 +0200
Subject: [PATCH] WIP:ALIGN

---
 .../implementation/kafka/KafkaServicesConfiguration.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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
-- 
2.20.1