From 1faba8e7ca7667dae0c91aa93c60f0e40937c02e Mon Sep 17 00:00:00 2001 From: lixiangrong Date: Sun, 24 Jul 2016 21:06:05 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0ActiveMQ=E7=A4=BA=E4=BE=8B?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../git/eh3/springamq/controller/ActivemqController.java | 2 -- .../eh3/springamq/mq/consumer/queue/QueueReceiver1.java | 3 --- .../eh3/springamq/mq/consumer/queue/QueueReceiver2.java | 4 ---- .../eh3/springamq/mq/consumer/topic/TopicReceiver1.java | 8 +------- .../eh3/springamq/mq/consumer/topic/TopicReceiver2.java | 4 ---- test.md | 7 ------- 6 files changed, 1 insertion(+), 27 deletions(-) delete mode 100644 test.md diff --git a/src/main/java/osc/git/eh3/springamq/controller/ActivemqController.java b/src/main/java/osc/git/eh3/springamq/controller/ActivemqController.java index 4f482ab..dc98598 100644 --- a/src/main/java/osc/git/eh3/springamq/controller/ActivemqController.java +++ b/src/main/java/osc/git/eh3/springamq/controller/ActivemqController.java @@ -11,8 +11,6 @@ import javax.annotation.Resource; /** - * - * @author liang * @description controller测试 */ @Controller diff --git a/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver1.java b/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver1.java index 3ebc902..52a78e7 100644 --- a/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver1.java +++ b/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver1.java @@ -9,10 +9,7 @@ import javax.jms.MessageListener; import javax.jms.TextMessage; /** - * - * @author liang * @description 队列消息监听器 - * */ @Component public class QueueReceiver1 implements MessageListener { diff --git a/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver2.java b/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver2.java index cc03b8e..abd6482 100644 --- a/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver2.java +++ b/src/main/java/osc/git/eh3/springamq/mq/consumer/queue/QueueReceiver2.java @@ -9,10 +9,7 @@ import javax.jms.MessageListener; import javax.jms.TextMessage; /** - * - * @author liang * @description 队列消息监听器 - * */ @Component public class QueueReceiver2 implements MessageListener { @@ -25,5 +22,4 @@ public class QueueReceiver2 implements MessageListener { e.printStackTrace(); } } - } diff --git a/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver1.java b/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver1.java index 8f7e619..b64a42a 100644 --- a/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver1.java +++ b/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver1.java @@ -7,17 +7,12 @@ import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; - /** - * - * @author liang * @description Topic消息监听器 - * */ @Component public class TopicReceiver1 implements MessageListener{ - @Override public void onMessage(Message message) { try { @@ -26,5 +21,4 @@ public class TopicReceiver1 implements MessageListener{ e.printStackTrace(); } } - -} +} \ No newline at end of file diff --git a/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver2.java b/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver2.java index 81b8205..814ac7e 100644 --- a/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver2.java +++ b/src/main/java/osc/git/eh3/springamq/mq/consumer/topic/TopicReceiver2.java @@ -8,15 +8,11 @@ import javax.jms.MessageListener; import javax.jms.TextMessage; /** - * - * @author liang * @description Topic消息监听器 - * */ @Component public class TopicReceiver2 implements MessageListener{ - @Override public void onMessage(Message message) { try { diff --git a/test.md b/test.md deleted file mode 100644 index 490cf82..0000000 --- a/test.md +++ /dev/null @@ -1,7 +0,0 @@ -**dfd** -~~ffff~~ -`dddd`d`d``` - -| d | -|---| -| df |