From ce6430a3ad528b578fa0dfccb808ca0196d12de1 Mon Sep 17 00:00:00 2001 From: kissrain Date: Mon, 20 Nov 2017 21:56:33 +0800 Subject: [PATCH] fix bug and change sout to log --- .../spring_boot/rabbitmq/delay/queue/ProcessReceiver.java | 5 ++++- .../queue/SpringBootRabbitmqDelayQueueApplicationTests.java | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/spring-boot-rabbitmq-delay-queue/src/main/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/ProcessReceiver.java b/spring-boot-rabbitmq-delay-queue/src/main/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/ProcessReceiver.java index f74dd2c..0162c50 100644 --- a/spring-boot-rabbitmq-delay-queue/src/main/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/ProcessReceiver.java +++ b/spring-boot-rabbitmq-delay-queue/src/main/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/ProcessReceiver.java @@ -1,6 +1,8 @@ package com.wooyoo.blog.spring_boot.rabbitmq.delay.queue; import com.rabbitmq.client.Channel; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.core.ChannelAwareMessageListener; import org.springframework.stereotype.Component; @@ -11,6 +13,7 @@ @Component public class ProcessReceiver implements ChannelAwareMessageListener { public static CountDownLatch latch; + private static Logger logger = LoggerFactory.getLogger(ProcessReceiver.class); public static final String FAIL_MESSAGE = "This message will fail"; @@ -38,7 +41,7 @@ public void onMessage(Message message, Channel channel) throws Exception { */ public void processMessage(Message message) throws Exception { String realMessage = new String(message.getBody()); - System.out.println("Received <" + realMessage + ">"); + logger.info("Received <" + realMessage + ">"); if (Objects.equals(realMessage, FAIL_MESSAGE)) { throw new Exception("Some exception happened"); } diff --git a/spring-boot-rabbitmq-delay-queue/src/test/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/SpringBootRabbitmqDelayQueueApplicationTests.java b/spring-boot-rabbitmq-delay-queue/src/test/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/SpringBootRabbitmqDelayQueueApplicationTests.java index 80d770a..7925df4 100644 --- a/spring-boot-rabbitmq-delay-queue/src/test/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/SpringBootRabbitmqDelayQueueApplicationTests.java +++ b/spring-boot-rabbitmq-delay-queue/src/test/java/com/wooyoo/blog/spring_boot/rabbitmq/delay/queue/SpringBootRabbitmqDelayQueueApplicationTests.java @@ -41,7 +41,7 @@ public void testDelayQueuePerQueueTTL() throws InterruptedException { public void testFailMessage() throws InterruptedException { ProcessReceiver.latch = new CountDownLatch(6); for (int i = 1; i <= 3; i++) { - rabbitTemplate.convertAndSend(QueueConfig.DELAY_QUEUE_PER_QUEUE_TTL_NAME, ProcessReceiver.FAIL_MESSAGE); + rabbitTemplate.convertAndSend(QueueConfig.DELAY_PROCESS_QUEUE_NAME, ProcessReceiver.FAIL_MESSAGE); } ProcessReceiver.latch.await(); }