import de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest;
import lombok.extern.slf4j.Slf4j;
-import org.apache.kafka.clients.consumer.Consumer;
-import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration;
@BeforeAll
static void sendAndLoadStoredData(
- @Autowired KafkaTemplate<String, String> messageTemplate,
- @Autowired ChannelTaskRunner channelTaskRunner)
+ @Autowired KafkaTemplate<String, String> messageTemplate)
{
KafkaTestUtils.sendAndLoadStoredData(
messageTemplate,
INFO_TOPIC,
- DATA_TOPIC,
- channelTaskRunner);
- }
-
- @AfterAll
- static void joinChannels(
- @Autowired Consumer dataChannelConsumer,
- @Autowired Consumer infoChannelConsumer,
- @Autowired ChannelTaskRunner channelTaskRunner)
- throws InterruptedException
- {
- dataChannelConsumer.wakeup();
- infoChannelConsumer.wakeup();
- channelTaskRunner.joinChannels();
+ DATA_TOPIC);
}
}