- log.info("Signaling the consumer of the CahtRoomChannel to quit its work");
- chatRoomChannelConsumer.wakeup();
- log.info("Waiting for the consumer of the ChatRoomChannel to finish its work");
- chatRoomChannelConsumerJob.join();
- log.info("Joined the consumer of the ChatRoomChannel");
+ log.info("Signaling the consumer-task for {} to quit its work", consumerTask);
+ consumer.wakeup();
+ log.info("Waiting for the consumer of {} to finish its work", consumerTask);
+ consumerTaskJob.join();
+ log.info("Joined the consumer-task for {}", consumerTask);