|
@@ -51,7 +51,7 @@ public class QuartzOrderlyImpl implements Orderly {
|
|
|
if (Objects.nonNull(mqDto.getAck()) && mqDto.getAck().intValue() != SystemConstant.STANDARD_ACK_TYPE && Objects.nonNull(redisUtil.get(SystemConstant.MQ_TOPIC_BUFFER_LIST, mqDto.getId())) && redisUtil.lock(SystemConstant.REDIS_LOCK_MQ_PREFIX + mqDto.getId(), SystemConstant.REDIS_LOCK_MQ_TIME_OUT)) {
|
|
|
try {
|
|
|
mqTaskLogicService.execMqQuartzLogic(mqDto, SystemConstant.MQ_TOPIC_BUFFER_LIST);
|
|
|
- return ConsumeOrderlyStatus.SUCCESS;
|
|
|
+// return ConsumeOrderlyStatus.SUCCESS;
|
|
|
} finally {
|
|
|
if (Objects.nonNull(mqDto)) {
|
|
|
redisUtil.releaseLock(SystemConstant.REDIS_LOCK_MQ_PREFIX + mqDto.getId());
|