public class KafkaServicesConfiguration
{
@Bean
- KafkaServicesApplicationRunner kafkaServicesApplicationRunner(
+ ConsumerTaskExecutor chatRoomChannelTaskExecutor(
ThreadPoolTaskExecutor taskExecutor,
ChatRoomChannel chatRoomChannel,
Consumer<String, AbstractMessageTo> chatRoomChannelConsumer,
- KafkaServicesApplicationRunner.WorkAssignor workAssignor)
+ ConsumerTaskExecutor.WorkAssignor workAssignor)
{
- return new KafkaServicesApplicationRunner(
+ return new ConsumerTaskExecutor(
taskExecutor,
chatRoomChannel,
chatRoomChannelConsumer,
}
@Bean
- KafkaServicesApplicationRunner.WorkAssignor workAssignor(
+ ConsumerTaskExecutor.WorkAssignor workAssignor(
ChatBackendProperties properties,
ChatRoomChannel chatRoomChannel)
{