From: Kai Moritz Date: Mon, 4 Mar 2024 14:11:30 +0000 (+0100) Subject: WIP:refactor: Refined channel-states, introduced `ChannelState` -- ALIGN X-Git-Tag: rebase--2024-03-05--09-07~4 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=54ea9135a8b959a3c2b96cf4e0cf6c20eefef2af;p=demos%2Fkafka%2Fchat WIP:refactor: Refined channel-states, introduced `ChannelState` -- 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 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); }