diff --git a/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/config/RabbitConfig.java b/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/config/RabbitConfig.java
index 3b37e917..1c5a36ce 100644
--- a/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/config/RabbitConfig.java
+++ b/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/config/RabbitConfig.java
@@ -11,7 +11,10 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class RabbitConfig {
 
-    public static class DirectorExchangeDemoConfiguration {
+    /**
+     * Direct Exchange 示例的配置类
+     */
+    public static class DirectExchangeDemoConfiguration {
 
         // 创建 Queue
         @Bean
@@ -41,7 +44,4 @@ public class RabbitConfig {
 
     }
 
-
-
-
 }
diff --git a/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/consumer/Demo01Consumer.java b/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/consumer/Demo01Consumer.java
index 1d85ad65..118e8b49 100644
--- a/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/consumer/Demo01Consumer.java
+++ b/lab-04/lab-04-rabbitmq-demo/src/main/java/cn/iocoder/springboot/lab04/rabbitmqdemo/consumer/Demo01Consumer.java
@@ -1,6 +1,8 @@
 package cn.iocoder.springboot.lab04.rabbitmqdemo.consumer;
 
 import cn.iocoder.springboot.lab04.rabbitmqdemo.message.Demo01Message;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
@@ -9,9 +11,16 @@ import org.springframework.stereotype.Component;
 @RabbitListener(queues = Demo01Message.QUEUE)
 public class Demo01Consumer {
 
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
     @RabbitHandler
     public void onMessage(Demo01Message message) {
-        System.out.println("Receiver : " + message);
+        logger.info("[onMessage][线程编号:{} 消息内容：{}]", Thread.currentThread().getId(), message);
     }
 
+//    @RabbitHandler(isDefault = true)
+//    public void onMessage(org.springframework.amqp.core.Message message) {
+//        logger.info("[onMessage][线程编号:{} 消息内容：{}]", Thread.currentThread().getId(), message);
+//    }
+
 }
diff --git a/lab-04/lab-04-rabbitmq-demo/src/main/resources/application.yaml b/lab-04/lab-04-rabbitmq-demo/src/main/resources/application.yaml
index 8ea7c4a4..59cf3bfb 100644
--- a/lab-04/lab-04-rabbitmq-demo/src/main/resources/application.yaml
+++ b/lab-04/lab-04-rabbitmq-demo/src/main/resources/application.yaml
@@ -1,7 +1,7 @@
 spring:
+  # RabbitMQ 配置项，对应 RabbitProperties 配置类
   rabbitmq:
     host: 127.0.0.1 # RabbitMQ 服务的地址
     port: 5672 # RabbitMQ 服务的端口
     username: guest # RabbitMQ 服务的账号
     password: guest # RabbitMQ 服务的密码
-    virtual-host:
diff --git a/lab-04/lab-04-rabbitmq-demo/src/test/java/cn/iocoder/springboot/lab04/rabbitmqdemo/producer/Demo01ProducerTest.java b/lab-04/lab-04-rabbitmq-demo/src/test/java/cn/iocoder/springboot/lab04/rabbitmqdemo/producer/Demo01ProducerTest.java
index c87c7a7f..3f5a8be8 100644
--- a/lab-04/lab-04-rabbitmq-demo/src/test/java/cn/iocoder/springboot/lab04/rabbitmqdemo/producer/Demo01ProducerTest.java
+++ b/lab-04/lab-04-rabbitmq-demo/src/test/java/cn/iocoder/springboot/lab04/rabbitmqdemo/producer/Demo01ProducerTest.java
@@ -42,7 +42,7 @@ public class Demo01ProducerTest {
     }
 
     @Test
-    public void testASyncSend() throws InterruptedException {
+    public void testAsyncSend() throws InterruptedException {
         int id = (int) (System.currentTimeMillis() / 1000);
         producer.asyncSend(id).addCallback(new ListenableFutureCallback<Void>() {