diff --git a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java b/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java
index 17a0ecec..fb7932ee 100644
--- a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java
+++ b/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java
@@ -140,8 +140,7 @@ public class RabbitMqClient {
     public Message getMessage(String messageType, Object msg) {
         MessageProperties messageProperties = new MessageProperties();
         messageProperties.setContentType(messageType);
-        Message message = new Message(msg.toString().getBytes(), messageProperties);
-        return message;
+        return new Message(msg.toString().getBytes(), messageProperties);
     }
 
     /**
@@ -163,7 +162,7 @@ public class RabbitMqClient {
      */
     public void sendMessageToExchange(TopicExchange topicExchange, AbstractExchange exchange, String msg) {
         addExchange(exchange);
-        logger.info("RabbitMQ send " + exchange.getName() + "->" + msg);
+        log.info("RabbitMQ send " + exchange.getName() + "->" + msg);
         rabbitTemplate.convertAndSend(topicExchange.getName(), msg);
     }
 
@@ -177,9 +176,7 @@ public class RabbitMqClient {
     public void sendMessage(String queueName, Object params) {
         log.info("发送消息到mq");
         try {
-            rabbitTemplate.convertAndSend(DelayExchangeBuilder.DELAY_EXCHANGE, queueName, params, message -> {
-                return message;
-            });
+            rabbitTemplate.convertAndSend(DelayExchangeBuilder.DELAY_EXCHANGE, queueName, params, message -> message);
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -261,7 +258,7 @@ public class RabbitMqClient {
         Binding binding = BindingBuilder.bind(queue).to(directExchange).withQueueName();
         rabbitAdmin.declareBinding(binding);
         String messages = (String) rabbitTemplate.receiveAndConvert(queueName);
-        System.out.println("Receive:" + messages);
+        log.info("Receive:" + messages);
         return messages;
     }