1 package de.juplo.kafka.chat.backend.implementation.kafka;
3 import lombok.RequiredArgsConstructor;
4 import lombok.extern.slf4j.Slf4j;
7 @RequiredArgsConstructor
9 public class ConsumerTaskRunner
11 private final ConsumerTaskExecutor infoChannelConsumerTaskExecutor;
12 private final ConsumerTaskExecutor dataChannelConsumerTaskExecutor;
14 public void executeConsumerTasks()
16 infoChannelConsumerTaskExecutor.executeConsumerTask();
17 dataChannelConsumerTaskExecutor.executeConsumerTask();
20 public void joinConsumerTasks()
22 dataChannelConsumerTaskExecutor.joinConsumerTaskJob();
23 infoChannelConsumerTaskExecutor.joinConsumerTaskJob();