ActiveMQSpringJMShowdoIgetthedelayIsetoncethemessageisconsumed?_网络技术

ActiveMQSpringJMShowdoIgetthedelayIsetoncethemessageisconsumed?

创始人

2024-05-21 01:49:21

0次

通过ActiveMQ Spring JMS使用delay功能后如何获取消费的延迟时间？要解决这个问题，可以在发送消息时给消息设置一个延迟时间，然后在消费消息时获取这个延迟时间。具体的解决方法可以使用ActiveMQ的延迟功能，在发送消息时设置延迟时间，在消费消息时从消息的属性中获取延迟时间。示例代码如下：

发送消息：

ActiveMQQueue destination = new ActiveMQQueue("test.queue");
jmsTemplate.convertAndSend(destination, message, new DelayMessagePostProcessor(delayTime));

消费消息：

Message message = messageConsumer.receive(5000);
if (message instanceof ActiveMQMessage) {
    ActiveMQMessage activeMQMessage = (ActiveMQMessage) message;
    long delayTime = activeMQMessage.getBrokerInTime() - activeMQMessage.getBrokerOutTime();
}

在消费消息时，从消息属性中获取延迟时间，即消息发出时间距离消息到达ActiveMQ Broker的时间，可以通过getBrokerInTime()和getBrokerOutTime()方法获取。

上一篇：ActivemqSpringBoot中的RedeliveryPolicy无法正常工作。

下一篇：ActiveMQSSL错误outboundhasclosed,ignoreoutboundalertmessage:close_notify

热门资讯

闲鱼搜索规则与技巧闲鱼最新特... 在闲鱼这个二手交易平台上，有很多用户都希望能够找到一些特殊的东西，比如一些罕见的收藏品、独特的手工艺...

玻璃硬盘原理图玻璃硬盘原理玻璃硬盘，又称为磁头悬浮硬盘（Magnetic Head Flying Disk，MHFD），是一种...

家里监控最长能保存多少天的记录... 家里监控一般保存多久随着科技的发展，家庭监控系统已经成为了许多家庭的必备设备，它不仅可以帮助我们...

QQ音乐提示代理模式可能无法正... QQ音乐提示代理模式可能无法正常访问，如上图所示，是怎么回事呢？这个可能和你的网络设置有关系，首先...

别人打电话听不见我说话怎么回事... 当我们在使用手机时，可能会遇到别人打电话过来听不见声音的情况，这种情况可能是由多种原因导致的，下面我...

ps5手柄可用手机快充充电吗 ... PS5手柄，即PlayStation 5的DualSense手柄，是索尼公司为PlayStation...

华为tag有用吗华为tag-... 华为Tag是华为手机中的一种功能，它可以帮助用户更好地管理自己的手机数据和应用，通过使用华为Tag，...

a100显卡对应的cuda版本在进行GPU加速的编程中，CUDA是常用的架构和平台，其版本和显卡型号之间存在着一定的对应关系。本篇...

frp内网穿透配置 HTTP ... HTTP 类型的代理相比于 TCP 类型，不仅在服务端只需要监听一个额外的端口 vhost_http...

hwid是永久激活吗 hwid... HWID，全称Hardware ID，是硬件识别码的缩写，它是计算机硬件制造商为了区分每一台设备而分...

ActiveMQSpringJMShowdoIgetthedelayIsetoncethemessageisconsumed?

相关内容

热门资讯