format

dromara · Jul 13, 2023 · 10b0b17 · 10b0b17
1 parent 13c00e3
commit 10b0b17
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/...apter-rabbitmq/src/main/java/org/dromara/dynamictp/example/controller/TestController.java b/...apter-rabbitmq/src/main/java/org/dromara/dynamictp/example/controller/TestController.java
@@ -33,11 +33,10 @@
 public class TestController {
 
     @Resource
-    RabbitTemplate rabbitTemplate;  //使用RabbitTemplate,这提供了接收/发送等等方法
+    RabbitTemplate rabbitTemplate;
 
     @GetMapping("/dtp-example-adapter/testRabbitMq")
     public String sendDirectMessage() {
-
         rabbitTemplate.convertAndSend("testQueue", "hello, dynamic-tp");
         return "ok";
     }

diff --git a/...ple-adapter-rabbitmq/src/main/java/org/dromara/dynamictp/example/mq/RabbitMqConsumer.java b/...ple-adapter-rabbitmq/src/main/java/org/dromara/dynamictp/example/mq/RabbitMqConsumer.java
@@ -32,12 +32,10 @@ public class RabbitMqConsumer {
 
     @RabbitListener(containerFactory = "rabbitListenerContainerFactory")
     @RabbitHandler
-    public void process(String text) throws InterruptedException {
+    public void process(String text) {
         Thread thread = Thread.currentThread();
         String name = thread.getName();
         long id = thread.getId();
-        //Thread.sleep(2000L);
-        //TimeUnit.SECONDS.sleep(1);
-        log.info("thread id :"+id+";thread name :"+name+"   Receiver  : " + text);
+        log.info("receive message: {}, thread name: {}, thread id: {}", text, name, id);
     }
 }