1 package de.juplo.kafka.chat.backend.implementation.kafka;
3 import lombok.RequiredArgsConstructor;
4 import lombok.extern.slf4j.Slf4j;
7 @RequiredArgsConstructor
9 public class ChannelTaskRunner
11 private final ChannelTaskExecutor infoChannelTaskExecutor;
12 private final ChannelTaskExecutor dataChannelTaskExecutor;
14 public void executeChannels()
16 infoChannelTaskExecutor.executeChannelTask();
17 dataChannelTaskExecutor.executeChannelTask();