新增redis消息队列

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

@@ -62,15 +62,14 @@ public class RedisMessageListener implements MessageListener {
         } catch (Exception e) {
             log.error("redis mq消息监听，消息消费出错", e);
             e.printStackTrace();
-            integer.set(SystemConstant.REDIS_MQ_MAX_RECONSUME);
-        } finally {
-            if (integer.get() == SystemConstant.REDIS_MQ_MAX_RECONSUME && Objects.nonNull(mqDto)) {//存入库
+            if (Objects.nonNull(mqDto)) {//存入库
                 Gson gson = new Gson();
                 mqDto.setAck(SystemConstant.POSION_ACK_TYPE);
                 TMMqMessage tmMqMessage = gson.fromJson(gson.toJson(mqDto), TMMqMessage.class);
                 tmMqMessage.setBody(JacksonUtil.parseJson(tmMqMessage.getBody()));
                 tmMqMessageService.saveOrUpdate(tmMqMessage);
             }
+        } finally {
             if (Objects.nonNull(mqDto) && (mqDto.getAck().intValue() == SystemConstant.STANDARD_ACK_TYPE
                     || mqDto.getAck().intValue() == SystemConstant.POSION_ACK_TYPE)) {
                 redisUtil.releaseLock(SystemConstant.REDIS_LOCK_MQ_PREFIX + mqDto.getId());