diff --git a/pom.xml b/pom.xml
index b746678b..fc0e627b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -73,6 +73,8 @@
 
         <jedis.version>2.9.0</jedis.version>
 
+        <lombok.version>1.18.4</lombok.version>
+
         <activemq.version>5.15.0</activemq.version>
         <rabbitmq.version>4.8.0</rabbitmq.version>
         <kafka.version>0.8.0</kafka.version>
@@ -427,6 +429,14 @@
                 <version>${jedis.version}</version>
             </dependency>
 
+            <dependency>
+                <groupId>org.projectlombok</groupId>
+                <artifactId>lombok</artifactId>
+                <version>${lombok.version}</version>
+                <scope>provided</scope>
+            </dependency>
+
+
             <!-- test -->
             <dependency>
                 <groupId>junit</groupId>
diff --git a/whatsmars-mq/pom.xml b/whatsmars-mq/pom.xml
index 038ab90a..c3ad7b1c 100644
--- a/whatsmars-mq/pom.xml
+++ b/whatsmars-mq/pom.xml
@@ -39,4 +39,11 @@
         </dependencies>
     </dependencyManagement>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+    </dependencies>
+
 </project>
\ No newline at end of file
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ConsumerApplication.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ConsumerApplication.java
deleted file mode 100644
index 6083989d..00000000
--- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ConsumerApplication.java
+++ /dev/null
@@ -1,31 +0,0 @@
-package org.hongxi.whatsmars.mq.rocketmq.boot;
-
-import org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.starter.core.RocketMQListener;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.stereotype.Service;
-
-@SpringBootApplication
-public class ConsumerApplication{
-    
-    public static void main(String[] args){
-        SpringApplication.run(ConsumerApplication.class, args);
-    }
-    
-    @Service
-    @RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1")
-    public class MyConsumer implements RocketMQListener<String> {
-        public void onMessage(String message) {
-            System.out.println("received message: " + message);
-        }
-    }
-    
-    @Service
-    @RocketMQMessageListener(topic = "test-topic-2", consumerGroup = "my-consumer_test-topic-2")
-    public class MyConsumer2 implements RocketMQListener<OrderPaidEvent>{
-        public void onMessage(OrderPaidEvent orderPaidEvent) {
-            System.out.println("received orderPaidEvent: " + orderPaidEvent);
-        }
-    }
-}
\ No newline at end of file
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java
index 6e1b1e41..1826e76e 100644
--- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java
@@ -1,33 +1,17 @@
 package org.hongxi.whatsmars.mq.rocketmq.boot;
 
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
 import java.io.Serializable;
 import java.math.BigDecimal;
 
+@NoArgsConstructor
+@AllArgsConstructor
+@Data
 public class OrderPaidEvent implements Serializable {
-        private String orderId;
-        
-        private BigDecimal paidMoney;
-
-        public OrderPaidEvent() {}
-
-        public OrderPaidEvent(String orderId, BigDecimal paidMoney) {
-            this.orderId = orderId;
-            this.paidMoney = paidMoney;
-        }
-
-        public String getOrderId() {
-            return orderId;
-        }
-
-        public void setOrderId(String orderId) {
-            this.orderId = orderId;
-        }
-
-        public BigDecimal getPaidMoney() {
-            return paidMoney;
-        }
 
-        public void setPaidMoney(BigDecimal paidMoney) {
-            this.paidMoney = paidMoney;
-        }
-    }
\ No newline at end of file
+    private String orderId;
+    private BigDecimal paidMoney;
+}
\ No newline at end of file
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/ConsumerApplication.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/ConsumerApplication.java
new file mode 100644
index 00000000..f8ae6cb1
--- /dev/null
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/ConsumerApplication.java
@@ -0,0 +1,13 @@
+package org.hongxi.whatsmars.mq.rocketmq.boot.consumer;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ConsumerApplication{
+    
+    public static void main(String[] args){
+        SpringApplication.run(ConsumerApplication.class, args);
+    }
+
+}
\ No newline at end of file
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/MyConsumer.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/MyConsumer.java
new file mode 100644
index 00000000..b3bcfc06
--- /dev/null
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/MyConsumer.java
@@ -0,0 +1,15 @@
+package org.hongxi.whatsmars.mq.rocketmq.boot.consumer;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.starter.core.RocketMQListener;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+@RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1")
+public class MyConsumer implements RocketMQListener<String> {
+    public void onMessage(String message) {
+        log.info("received message: " + message);
+    }
+}
\ No newline at end of file
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/MyConsumer2.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/MyConsumer2.java
new file mode 100644
index 00000000..d0743288
--- /dev/null
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/consumer/MyConsumer2.java
@@ -0,0 +1,16 @@
+package org.hongxi.whatsmars.mq.rocketmq.boot.consumer;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.starter.core.RocketMQListener;
+import org.hongxi.whatsmars.mq.rocketmq.boot.OrderPaidEvent;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+@RocketMQMessageListener(topic = "test-topic-2", consumerGroup = "my-consumer_test-topic-2")
+public class MyConsumer2 implements RocketMQListener<OrderPaidEvent> {
+    public void onMessage(OrderPaidEvent orderPaidEvent) {
+        log.info("received orderPaidEvent: " + orderPaidEvent);
+    }
+}
\ No newline at end of file
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ProducerApplication.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/producer/ProducerApplication.java
similarity index 59%
rename from whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ProducerApplication.java
rename to whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/producer/ProducerApplication.java
index cd0abb8c..e0962bea 100644
--- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ProducerApplication.java
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/producer/ProducerApplication.java
@@ -1,6 +1,7 @@
-package org.hongxi.whatsmars.mq.rocketmq.boot;
+package org.hongxi.whatsmars.mq.rocketmq.boot.producer;
 
 import org.apache.rocketmq.spring.starter.core.RocketMQTemplate;
+import org.hongxi.whatsmars.mq.rocketmq.boot.OrderPaidEvent;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
@@ -19,9 +20,15 @@ public static void main(String[] args){
     }
     
     public void run(String... args) throws Exception {
-        rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
-        rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload("Hello, World! I'm from spring message").build());
-        rocketMQTemplate.convertAndSend("test-topic-2", new OrderPaidEvent("T_001", new BigDecimal("88.00")));
+        for (int i = 0; i < 20; i++) {
+            try {
+                rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
+                rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload("Hello, World! I'm from spring message").build());
+                rocketMQTemplate.convertAndSend("test-topic-2", new OrderPaidEvent("T_001", new BigDecimal("88.00")));
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
         
 //        rocketMQTemplate.destroy(); // notes:  once rocketMQTemplate be destroyed, you can not send any message again with this rocketMQTemplate
     }