修复优惠卷问题 修复售后订单问题
This commit is contained in:
@ -63,6 +63,8 @@ public class RedisPendingMessageResendJob {
|
||||
// 从消费者的 pending 队列中读取消息
|
||||
List<MapRecord<String, Object, Object>> records = ops.read(Consumer.from(groupName, consumerName), StreamOffset.create(listener.getStreamKey(), ReadOffset.from("0")));
|
||||
if (CollUtil.isEmpty(records)) {
|
||||
assert records != null;
|
||||
log.info(records.toString());
|
||||
return;
|
||||
}
|
||||
for (MapRecord<String, Object, Object> record : records) {
|
||||
|
Reference in New Issue
Block a user