|
|
|
@ -421,7 +421,7 @@ public class RedisStreamConsumer { |
|
|
|
|
|
|
|
boolean reclaimTerminated = reclaimScheduler.awaitTermination(10, TimeUnit.SECONDS); |
|
|
|
|
|
|
|
log.info("RedisStreamConsumer shutdown done, consumerTerminated={}, workerTterminated={}, reclaimTerminated={}", |
|
|
|
log.info("RedisStreamConsumer shutdown done, consumerTerminated={}, workerTerminated={}, reclaimTerminated={}", |
|
|
|
consumerTerminated, |
|
|
|
workerTerminated, |
|
|
|
reclaimTerminated); |
|
|
|
|