rabbbitmq

4dkankan-utils-rabbitmq/src/main/java/com/fdkankan/rabbitmq/callback/ProducerCallback.java

@@ -21,13 +21,15 @@ public class ProducerCallback implements RabbitTemplate.ConfirmCallback,RabbitTe
     //confirms模式：无论exchange投递消息是成功或是失败，都会返回ack，我们可以根据返回的ack是成功还是失败，做相应的业务处理
     @Override
     public void confirm(CorrelationData correlationData, boolean ack, String cause) {
+        String messageId = correlationData.getReturnedMessage().getMessageProperties()
+            .getMessageId();
         //投递成功
         if(ack){
-            log.info("消息投递成功，id:{}", correlationData.getId());
+            log.info("消息投递成功，id:{}", messageId);
             return;
         }
         //投递失败
-        log.error("消息投递失败，id:{}，失败原因:{}", correlationData.getId(), cause);
+        log.error("消息投递失败，id:{}，失败原因:{}", messageId, cause);
     }
 
     //return模式：只有exchange投递消息失败时，才会执行回调函数，来做一些相应的业务处理