- log.info("Waiting for the consumer of {} to finish its work", consumerTask);
- consumerTaskJob.join();
- log.info("Joined the consumer-task for {}", consumerTask);
+ log.info("Waiting for the consumer of {} to finish its work", channel);
+ channelTaskJob.join();
+ log.info("Joined the consumer-task for {}", channel);