Skip to main content

ConsumeJMS

描述:

消费BytesMessage或TextMessage类型的JMS消息,将消息内容转换为流文件内容,并将流文件路由到'成功'连线。JMS的属性(如消息头和属性)会被拷贝作为流文件的属性。

标签:

jms, get, message, receive, consume, 消息, 接收, 消费

参数:

如下列表中,必填参数则标识为加粗. 其他未加粗参数,则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 orchsym.properties 文件中存在属性设置 orchsym.sensitive.props.key.

名字默认值允许值列表描述
Connection Factory服务控制器服务API:
JMSConnectionFactoryProviderDefinition
实现:
JMSConnectionFactoryProvider
用于获取ConnectionFactory的控制器服务
目的地名称JMS目的地的名称,通常由管理员提供。例如:'topic://myTopic' 或 'myTopic'。

支持表达式语言 (仅支持变量)
目的地类型队列
- 队列
- 主题
JMS目的地的类型。可以是“队列”或“主题”其中之一。通常由管理员提供,默认为“队列”。
用户名用于身份验证和授权的用户名。
密码用于身份验证和授权的密码。

敏感状态
连接客户id用于设置在连接上的客户id。对于持久(durable)非共享的消费者,此项是必须的,对于其它消费者则是可选的。对于共享消费者,通常不希望设置此项,有关详细信息,请参阅JMS规范。

支持表达式语言 (仅支持变量)
会话缓存大小1此属性已被弃用,对组件不再有任何影响,它将在以后的版本中被删除。
字符编码UTF-8用于构建或解释文本消息(TextMessages)的字符集编码。

支持表达式语言 (仅支持变量)
确认模式客户端确认 (2)
- 自动确认 (1)自动确认客户端收到的消息,无论是否已提交Orchsym会话。如果在会话提交之前Orchsym突然停止,可能会导致数据丢失。
- 客户端确认 (2)(默认)在提交Orchsym会话后手动确认客户端收到的消息,从而确保没有数据丢失。
- 允许重复消息 (3)这种确认模式会指示会话(session)延迟确认消息的传递,在获得最佳吞吐量的同时,可能会导致数据重复和数据丢失。
JMS确认模式。使用自动确认模式可能会在重启Orchsym时丢失消息,但可能比客户端确认模式有更好的性能。
持久化订阅
- 是
- 否
如果目标是主题(如果存在),则让该主题能够持久消费。查阅https://docs.oracle.com/javaee/7/api/javax/jms/Session.html#createDurableConsumer-javax.jms.Topic-java.lang.String-

支持表达式语言 (仅支持变量)
共享订阅
- 是
- 否
如果目标是主题(如果存在),则使主题消费者之间共享。查阅:https://docs.oracle.com/javaee/7/api/javax/jms/Session.html#createSharedDurableConsumer-javax.jms.Topic-java.lang.String-

支持表达式语言 (仅支持变量)
订阅名称订阅名称。如果目的地是主题,主题共享且持久化,则使用的订阅名称。

支持表达式语言 (仅支持变量)

连线:

名字描述
success从JMS目的地接收的所有流文件都被路由到此连线。

读取属性:

未提供。

写入属性:

名字描述
jms_deliveryMode消息头中的投递模式
jms_expiration消息头中的过期时间
jms_priority消息头中的消息优先级
jms_redelivered消息头中的JMSRedelivered内容。
jms_timestamp消息头中的时间戳
jms_correlationId消息头中的JMSCorrelationID内容。
jms_messageId消息头中的消息ID
jms_type消息头中的消息类型
jms_replyTo消息头中的答复方
jms_destination消息头中的目的地
other attributes每个消息属性都被写入到一个属性中。

状态管理:

该组件不保存状态。

限制:

该组件没有限制

输入流要求:

组件禁止提供输入流。

系统资源考量:

未提供。

参考:

JMSConnectionFactoryProvider, PublishJMS