升级新版本

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

@@ -107,7 +107,8 @@ public class MqServiceImpl implements MqService {
 
     @Override
     public void basicHandle(Message messageBody, Channel channel, String message, Consumer<String> consumerMessage) {
-        this.basicHandle(messageBody, channel, StringHelper.EMPTY, StringHelper.EMPTY, message, 0, consumerMessage);
+        String consumerQueue = messageBody.getMessageProperties().getConsumerQueue();
+        this.basicHandle(messageBody, channel, consumerQueue, consumerQueue, message, 0, consumerMessage);
     }
 
     @Override