博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
JMS消息头
阅读量:5296 次
发布时间:2019-06-14

本文共 1227 字,大约阅读时间需要 4 分钟。

一个消息对象分为三部分:消息头(Headers),属性(Properties)和消息体(Payload)。对于StreamMessageMapMessage,消息本身就有特定的结构,而对于TextMessageObjectMessageBytesMessage是无结构的。一个消息可以包含一些重要的数据或者仅仅是一个事件的通知。

    消息的Headers部分通常包含一些消息的描述信息,它们都是标准的描述信息。包含下面一些值:

  JMSDestination

       消息的目的地,Topic或者是Queue

  JMSDeliveryMode

       消息的发送模式:persistentnonpersistent。前者表示消息在被消费之前,如果JMS提供者DOWN了,重新启动后消息仍然存在。后者在这种情况下表示消息会被丢失。可以通过下面的方式设置:

       Producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

       JMSTimestamp

       当调用send()方法的时候,JMSTimestamp会被自动设置为当前事件。可以通过下面方式得到这个值:

       long timestamp = message.getJMSTimestamp();

 

  JMSExpiration

       表示一个消息的有效期。只有在这个有效期内,消息消费者才可以消费这个消息。默认值为0,表示消息永不过期。可以通过下面的方式设置:

       producer.setTimeToLive(3600000); //有效期1小时1000毫秒 * 60 * 60分)

  JMSPriority

       消息的优先级。0-4为正常的优先级,5-9为高优先级。可以通过下面方式设置:

       producer.setPriority(9);

  JMSMessageID

       一个字符串用来唯一标示一个消息。

  JMSReplyTo

       有时消息生产者希望消费者回复一个消息,JMSReplyTo为一个Destination,表示需要回复的目的地。当然消费者可以不理会它。

  JMSCorrelationID

       通常用来关联多个Message。例如需要回复一个消息,可以把JMSCorrelationID设置为所收到的消息的JMSMessageID

  JMSType

       表示消息体的结构,和JMS提供者有关。

  JMSRedelivered

       如果这个值为true,表示消息是被重新发送了。因为有时消费者没有确认他已经收到消息或者JMS提供者不确定消费者是否已经收到。

    除了Header,消息发送者可以添加一些属性(Properties)。这些属性可以是应用自定义的属性,JMS定义的属性和JMS提供者定义的属性。我们通常只适用自定义的属性。

    后面会讲到这些Header和属性的用法。

转载于:https://www.cnblogs.com/fjhh/p/5370564.html

你可能感兴趣的文章
字符串压缩
查看>>
用Lua定制Redis命令
查看>>
小程序-canvas在IOS手机层级最高无法展示问题
查看>>
「 Luogu P2285 」打鼹鼠
查看>>
lua语言入门之Sublime Text设置lua的Build System
查看>>
解决win8使用内置管理员不能打开应用商城、天气等问题
查看>>
vue.js基础
查看>>
电脑的自带图标的显示
查看>>
globalization与全球化
查看>>
[转载] redis 的两种持久化方式及原理
查看>>
关于在Idea 创建Maven项目时,无法在source文件下创建servlet文件问题解决!
查看>>
对 HTTP 304 的理解
查看>>
深入理解css中的margin属性
查看>>
C++ 删除字符串的两种实现方式
查看>>
电容选型
查看>>
ORA-01502: 索引'P_ABCD.PK_WEB_BASE'或这类索引的分区处于不可用状态
查看>>
Spring EL hello world实例
查看>>
百度地图API地理位置和坐标转换
查看>>
MyBatis学习总结(六)——调用存储过程
查看>>
code-代码平台服务器路径
查看>>