activemq使用delay详解

it2025-06-20  3

1. 发送代码

String messageStr = "delay 120s message - "+i; // 延时 120秒 TextMessage message = session.createTextMessage(messageStr); message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 120 * 1000L);

 2.  在管理端的schedued上去看数据

3.  Producer打印

2019-08-04 00:49:15,send delay 120s message - 1 2019-08-04 00:49:18,send delay 120s message - 2 2019-08-04 00:49:21,send delay 120s message - 3 2019-08-04 00:49:24,send delay 120s message - 4 2019-08-04 00:49:27,send delay 120s message - 5 2019-08-04 00:49:30,send delay 120s message - 6 2019-08-04 00:49:33,send delay 120s message - 7 2019-08-04 00:49:36,send delay 120s message - 8 2019-08-04 00:49:39,send delay 120s message - 9 2019-08-04 00:49:42,send delay 120s message - 10

 

4. 在Consumer打印

2019-08-04 00:51:16,CommonConsumer订阅者一收到的消息:delay 120s message - 1 2019-08-04 00:51:19,CommonConsumer订阅者一收到的消息:delay 120s message - 2 2019-08-04 00:51:22,CommonConsumer订阅者一收到的消息:delay 120s message - 3 2019-08-04 00:51:25,CommonConsumer订阅者一收到的消息:delay 120s message - 4 2019-08-04 00:51:28,CommonConsumer订阅者一收到的消息:delay 120s message - 5 2019-08-04 00:51:31,CommonConsumer订阅者一收到的消息:delay 120s message - 6 2019-08-04 00:51:34,CommonConsumer订阅者一收到的消息:delay 120s message - 7 2019-08-04 00:51:37,CommonConsumer订阅者一收到的消息:delay 120s message - 8 2019-08-04 00:51:40,CommonConsumer订阅者一收到的消息:delay 120s message - 9 2019-08-04 00:51:43,CommonConsumer订阅者一收到的消息:delay 120s message - 10

 

5. 通过Consumer-Producer,每条时间这里相差121S

 

 

 

 

 

 

 

 

 

 

 

 

最新回复(0)