import de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest;
import lombok.extern.slf4j.Slf4j;
-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 ChannelTaskExecutor dataChannelTaskExecutor,
- @Autowired ChannelTaskExecutor infoChannelTaskExecutor)
- {
- dataChannelTaskExecutor.join();
- infoChannelTaskExecutor.join();
+ DATA_TOPIC);
}
}