表结构修改

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -37,7 +37,7 @@ public class MqServiceImpl implements MqService {
     private MessageServerService messageServerService;
     @Autowired
     private MessageLogService messageLogService;
-
+    private final static long DED_TIME_DEFAULT = 3L * 1000L;
     /**
      * 保存演示DEMO
      *
@@ -108,7 +108,7 @@ public class MqServiceImpl implements MqService {
     @Override
     public void basicHandle(Message messageBody, Channel channel, String message, Consumer<String> consumerMessage) {
         String consumerQueue = messageBody.getMessageProperties().getConsumerQueue();
-        this.basicHandle(messageBody, channel, consumerQueue, consumerQueue, message, 0, consumerMessage);
+        this.basicHandle(messageBody, channel, consumerQueue, consumerQueue, message, DED_TIME_DEFAULT, consumerMessage);
     }
 
     @Override
@@ -119,7 +119,7 @@ public class MqServiceImpl implements MqService {
 
     @Override
     public void basicHandle(Message messageBody, Channel channel, String exchangeNameAndRouteKey, String message, Consumer<String> consumerMessage) {
-        this.basicHandle(messageBody, channel, exchangeNameAndRouteKey, exchangeNameAndRouteKey, message, 0, consumerMessage);
+        this.basicHandle(messageBody, channel, exchangeNameAndRouteKey, exchangeNameAndRouteKey, message, DED_TIME_DEFAULT, consumerMessage);
     }
 
     @Override