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) - 客户端确认 (2) - 允许重复消息 (3) | 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 | 每个消息属性都被写入到一个属性中。 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件禁止提供输入流。
系统资源考量:
未提供。