fix bug and change sout to log

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");
         }

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();
     }