|
@@ -67,7 +67,7 @@ public class DefaultRedisMQListenerContainer<T> implements RedisMQListenerContai
|
|
Consumer source = Consumer.from(consumer.groupName(), consumer.consumerName());
|
|
Consumer source = Consumer.from(consumer.groupName(), consumer.consumerName());
|
|
if (consumer.pendingCount() == 0) {
|
|
if (consumer.pendingCount() == 0) {
|
|
RedisStreamHolder.delete(this.topic, source);
|
|
RedisStreamHolder.delete(this.topic, source);
|
|
- log.info("RedisMQ consumer deleted: {}", source);
|
|
|
|
|
|
+ log.info("RedisMQ consumer discarded: {}", source);
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
new ConsumerPendingCleaner<>(this.topic, source, this.consumer, this.listener, this.executor).start();
|
|
new ConsumerPendingCleaner<>(this.topic, source, this.consumer, this.listener, this.executor).start();
|