From 94a6bc108f497fc0f6ddf9ebd82d7f0bd92638b8 Mon Sep 17 00:00:00 2001 From: YunaiV <> Date: Sat, 14 Dec 2019 23:38:46 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=20activemq=20=E7=A4=BA?= =?UTF-8?q?=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 1 + .../springboot/lab32/activemqdemo/ActiveMQConsumer.java | 3 ++- .../springboot/lab32/activemqdemo/ActiveMQProducer.java | 4 ++-- 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 1a6f1d91..f1086942 100644 --- a/README.md +++ b/README.md @@ -45,6 +45,7 @@ * [《芋道 Spring Boot 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Boot/RocketMQ/?github) 对应 [lab-31](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-31) 。 * [《芋道 Spring Boot 消息队列 Kafka 入门》](http://www.iocoder.cn/Spring-Boot/Kafka/?github) 对应 [lab-03](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-03) 。 * [《芋道 Spring Boot 消息队列 RabbitMQ 入门》](http://www.iocoder.cn/Spring-Boot/RabbitMQ/?github) 对应 [lab-04](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-04) 。 +* [《芋道 Spring Boot 消息队列 ActiveMQ 入门》](http://www.iocoder.cn/Spring-Boot/ActiveMQ/?github) 对应 [lab-32](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-32) 。 ## 性能测试 diff --git a/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQConsumer.java b/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQConsumer.java index e8a36ed3..0c0d16d7 100644 --- a/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQConsumer.java +++ b/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQConsumer.java @@ -1,6 +1,7 @@ package cn.iocoder.springboot.lab32.activemqdemo; -import javax.jms.*; +import javax.jms.*; // 使用 JMS API + import java.util.concurrent.TimeUnit; public class ActiveMQConsumer { diff --git a/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQProducer.java b/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQProducer.java index c8997b58..061eb4a0 100644 --- a/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQProducer.java +++ b/lab-32/lab-32-activemq-native/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/ActiveMQProducer.java @@ -1,8 +1,8 @@ package cn.iocoder.springboot.lab32.activemqdemo; -import org.apache.activemq.ActiveMQConnectionFactory; +import org.apache.activemq.ActiveMQConnectionFactory; // 使用 ActiveMQ 的客户端实现 -import javax.jms.*; +import javax.jms.*; // 使用 JMS API public class ActiveMQProducer {