新增redis消息队列

distributed-print/src/main/java/com/qmth/distributed/print/config/RedisMessageListener.java

@@ -39,7 +39,7 @@ public class RedisMessageListener implements MessageListener {
             if (Objects.nonNull(body)) {
                 mqDto = JacksonUtil.readJson(body.substring(1, body.length() - 1), MqDto.class);
                 for (; integer.get() < mqDto.getReconsume(); integer.incrementAndGet()) {
-                    log.info("integer:{}", integer.get());
+                    log.info("reconsume:{}", integer.get());
                     if (Objects.nonNull(mqDto.getAck()) && mqDto.getAck().intValue() != SystemConstant.STANDARD_ACK_TYPE
                             && redisUtil.lock(SystemConstant.REDIS_LOCK_MQ_PREFIX + mqDto.getId(),
                             SystemConstant.REDIS_LOCK_MQ_TIME_OUT)) {