fix

朱晔 · 朱晔 · commit 2d4b33f6032f · 2020-06-11T21:56:51.000+08:00
diff --git a/src/main/java/org/geekbang/time/commonmistakes/asyncprocess/rabbitmqdlx/DeadLetterController.java b/src/main/java/org/geekbang/time/commonmistakes/asyncprocess/rabbitmqdlx/DeadLetterController.java
@@ -20,6 +20,8 @@ public class DeadLetterController {
 
     @GetMapping("send")
     public void send() {
-        rabbitTemplate.convertAndSend(Consts.EXCHANGE, Consts.QUEUE, "msg" + atomicLong.incrementAndGet());
+        String message = "msg" + atomicLong.incrementAndGet();
+        log.info("Client 发送消息 {}", message);
+        rabbitTemplate.convertAndSend(Consts.EXCHANGE, Consts.QUEUE, message);
     }
 }
diff --git a/src/main/java/org/geekbang/time/commonmistakes/asyncprocess/rabbitmqdlx/MQListener.java b/src/main/java/org/geekbang/time/commonmistakes/asyncprocess/rabbitmqdlx/MQListener.java
@@ -24,14 +24,13 @@ public class MQListener {
     public void handler(@Payload Message message, Channel channel) throws IOException {
         String m = new String(message.getBody());
         try {
-            log.info("收到消息：{}", m);
+            log.info("Handler 收到消息：{}", m);
             throw new RuntimeException("处理消息失败");
         } catch (Exception e) {
             Map<String, Object> headers = message.getMessageProperties().getHeaders();
             Long retryCount = getRetryCount(headers);
-            //重试3次
             if (retryCount < Consts.RETRY_COUNT) {
-                log.info("消费消息：{} 异常，准备重试第{}次", m, ++retryCount);
+                log.info("Handler 消费消息：{} 异常，准备重试第{}次", m, ++retryCount);
 
                 AMQP.BasicProperties rabbitMQProperties =
                         messagePropertiesConverter.fromMessageProperties(message.getMessageProperties(), "UTF-8");
@@ -60,6 +59,6 @@ private long getRetryCount(Map<String, Object> headers) {
 
     @RabbitListener(queues = Consts.DEAD_QUEUE)
     public void deadHandler(@Payload Message message) {
-        log.error("收到死信消息： {}", new String(message.getBody()));
+        log.error("DeadHandler 收到死信消息： {}", new String(message.getBody()));
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -20,6 +20,8 @@ public class DeadLetterController {`
`20`	`20`
`21`	`21`	`@GetMapping("send")`
`22`	`22`	`public void send() {`
`23`		`- rabbitTemplate.convertAndSend(Consts.EXCHANGE, Consts.QUEUE, "msg" + atomicLong.incrementAndGet());`
	`23`	`+ String message = "msg" + atomicLong.incrementAndGet();`
	`24`	`+ log.info("Client 发送消息 {}", message);`
	`25`	`+ rabbitTemplate.convertAndSend(Consts.EXCHANGE, Consts.QUEUE, message);`
`24`	`26`	`}`
`25`	`27`	`}`