@Slf4j
public class KafkaServicesApplicationRunner implements ApplicationRunner
{
- private final ConsumerTaskExecutor chatRoomChannelTaskExecutor;
+ private final ChannelTaskRunner channelTaskRunner;
@Override
- public void run(ApplicationArguments args) throws Exception
+ public void run(ApplicationArguments args)
{
- chatRoomChannelTaskExecutor.executeConsumerTask();
+ log.info("Executing channel-tasks");
+ channelTaskRunner.executeChannels();
}
}