From 54ea9135a8b959a3c2b96cf4e0cf6c20eefef2af Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 4 Mar 2024 15:11:30 +0100 Subject: [PATCH] WIP:refactor: Refined channel-states, introduced `ChannelState` -- ALIGN --- .../implementation/kafka/KafkaServicesConfiguration.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 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 81655894..1088cabf 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 @@ -40,13 +40,13 @@ public class KafkaServicesConfiguration { @Bean ChannelTaskRunner consumerTaskRunner( - ChannelTaskExecutor infoChannelChannelTaskExecutor, - ChannelTaskExecutor dataChannelChannelTaskExecutor, + ChannelTaskExecutor infoChannelTaskExecutor, + ChannelTaskExecutor dataChannelTaskExecutor, InfoChannel infoChannel) { return new ChannelTaskRunner( - infoChannelChannelTaskExecutor, - dataChannelChannelTaskExecutor, + infoChannelTaskExecutor, + dataChannelTaskExecutor, infoChannel); } -- 2.20.1