增加 activemq 示例

This commit is contained in:
YunaiV
2019-12-14 23:38:46 +08:00
parent 27f594b491
commit 94a6bc108f
3 changed files with 5 additions and 3 deletions

View File

@@ -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) 。
## 性能测试

View File

@@ -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 {

View File

@@ -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 {