合并空行ＢＵＧ

yzg-util-mq/src/main/java/com/yanzuoguang/mq/base/MqConfigurable.java

@@ -5,11 +5,8 @@ import com.yanzuoguang.mq.vo.MessageVo;
 import com.yanzuoguang.util.helper.StringHelper;
 import com.yanzuoguang.util.log.Log;
 import org.springframework.amqp.core.Message;
-import org.springframework.amqp.core.MessageListener;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
-import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
 import org.springframework.amqp.rabbit.support.CorrelationData;
 import org.springframework.beans.factory.annotation.Configurable;
 import org.springframework.context.annotation.Bean;
@@ -20,6 +17,7 @@ import java.nio.charset.Charset;
 
 /**
  * MQ队列相关配置信息
+ *
  * @author 颜佐光
  */
 @Configurable
@@ -67,10 +65,10 @@ public class MqConfigurable implements RabbitTemplate.ConfirmCallback, RabbitTem
                 String toId = getId(correlationData.getId());
                 // 不是临时数据
                 if (toId.equals(correlationData.getId())) {
-                    messageService.onSuccess(getId(correlationData.getId()));
+                    messageService.onSuccess(toId);
                 }
             } else if (!ack) {
-                System.out.println("丢失消息:" + ack);
+                System.out.println("丢失消息:" + ack + " msg:" + cause);
             }
         } catch (Exception ex) {
             Log.error(MqConfigurable.class, ex);