修复RabbitMQ 重发bug

Author: xiaolyuh123

spring-boot-student-rabbitmq/src/main/java/com/xiaolyuh/mq/sender/RabbitSender.java

@@ -50,6 +50,9 @@ public void sendMessage(String exchangeName, String routingKey, Object message)
 
         // 获取CorrelationData对象
         CorrelationData correlationData = this.correlationData(message);
+        correlationData.setExchange(exchangeName);
+        correlationData.setRoutingKey(routingKey);
+        correlationData.setMessage(message);
 
         logger.info("发送MQ消息，消息ID：{}，消息体:{}, exchangeName:{}, routingKey:{}",
                 correlationData.getId(), JSON.toJSONString(message), exchangeName, routingKey);

spring-boot-student-rabbitmq/src/main/resources/application.properties

@@ -1,4 +1,4 @@
-server.port=80
+server.port=8081
 
 # Rabbitmq
 spring.rabbitmq.username=guest