当前位置: 首页 > 知识库问答 >
问题:

ActiveMQ JMS 消息选择

席乐童
2023-03-14

在Java中,是否可以从带有JMS和ActiveMQ的队列中选择一条消息,知道其相关性ID?

这个想法是能够知道一条消息是以前发送过的消息的响应。

共有1个答案

邓正真
2023-03-14

下面是如何处理相关 ID 的完整示例。

JMS 规范中的关键方法是 getJMSCorrelationID 和 setJMSCorrelationID。

 类似资料:
  • 我正在使用RestTemboard类发布到基于JSON的RESTful Web服务。我可以从留档中看到,可以有几个MessageConverters可用于RestTem板实例。我面临的问题是,客户端似乎出于某种原因选择使用基于XML的转换器。“内容类型”标头设置为应用程序/XML,消息主体包含我想作为JSON发送的对象的XML表示。如何最容易地配置我的RestTemboard实例,以便为我的请求使

  • 消息组件为你的App提供了可视评论和消息系统。 消息组件布局 ... <div class="page"> <div class="page-content messages-content"> <div class="messages"> <!-- 时间戳 --> <div class="messages-date">Sunday, Feb 9 <spa

  • Unread message count(未读消息统计) GET /user/counts 响应: Status: 200 OK { "user": { // 用户相关 "following": 1, // 用户关注者新增(粉丝新增)数量 "liked": 0, // 被点赞数 "commented": 0, // 被评论数 "system": 0,

  • 公众号消息分为 服务端被动回复消息 和 客服消息 两个场景。 需要注意的是两个场景的消息虽然类似,但是结构却有些差异,比如服务端使用 XML 结构,而客服消息使用 JSON 结构,且同样类似的消息类型,结构和名称都有些许差异,在使用时请勿混淆。 服务端消息结构 当你接收到用户发来的消息时,可能会提取消息中的相关属性,参考: 请求消息基本属性(以下所有消息都有的基本属性): - `ToUserN

  • 我把微信的 API 里的所有“消息”都按类型抽象出来了,也就是说,你不用区分它是回复消息还是主动推送消息,免去了你去手动拼装微信的 XML 以及乱七八糟命名不统一的 JSON 了。 在阅读以下内容时请忽略是 接收消息 还是 回复消息,后面我会给你讲它们的区别。 消息类型 消息分为以下几种:文本、图片、视频、声音、链接、坐标、图文、文章 和一种特殊的 原始消息。 另外还有一种特殊的消息类型:素材消息

  • 注:内容翻译自官网文档 Messages 给出一个简单的消息定义: message Foo {} protocol buffer 编译器生成名为 Foo 的类,实现 Message 接口。这个类被定义为 final, 不容许任何子类。Foo 继承自 GeneratedMessage, 但是这个可以认为是实现细节。默认, Foo 用为实现最大速度的特别版本来覆盖很多 GeneratedMessag

  • 有一个SQS队列,我在其中不断收到消息。我只需要阅读和处理过去24小时内收到的信息。目前收到的信息应在第二天处理<代码>时间戳存储在消息正文中。 是否可以从SQS队列中选择性地读取消息。例如,只读那些值大于前一天的时间戳但小于当前时间戳(当前时间戳是此作业运行的时间)的消息?

  • 本文向大家介绍如何做的消息队列选型,为什么选择kafka?相关面试题,主要包含被问及如何做的消息队列选型,为什么选择kafka?时的应答技巧和注意事项,需要的朋友参考一下 kafka和rocketmq吞吐量可达百万级,比activemq、rabbitmq要高一个数量级 kafka和rocketmq都是分布式架构,高可用 kafka和rocketmq都是毫秒级低延时,rocketmq甚至到微秒级 r