PublishJMS 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-jms-processors-nar
描述¶
基于 FlowFile 内容创建 JMS 消息，并将其作为 JMS BytesMessage 或 TextMessage 发送至 JMS 目标（队列或主题）。FlowFile 属性将被添加为传出 JMS 消息的 JMS 标头和/或属性。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
连接客户端 ID |
要在连接上设置的客户端 ID（如果已设置）。对于持久化非共享使用者，此属性为必选项；对于其他所有类型使用者，则为可选项，通常不建议为共享使用者配置此属性。请参阅 JMS 规格，以获取更多详细信息 |
连接工厂服务 |
用于获取连接工厂的控制器服务。此外，“JNDI *”或“JMS *”属性也可用于配置连接工厂。 |
目标名称 |
JMS 目标的名称。通常由管理员提供（例如，“topic://myTopic”或“myTopic”）。 |
目标类型 |
JMS 目标的类型。可能是“QUEUE”或“TOPIC”之一。通常由管理员提供。默认值为“QUEUE”。 |
最大批处理大小 |
每次调用处理器时要发布或使用的最大消息数。 |
密码 |
用于身份验证与授权的密码。 |
SSL Context Service |
用于为 TLS/SSL 连接提供客户端证书信息的 SSL Context Service。 |
用户名 |
用于身份验证和授权的用户名。 |
allow-illegal-chars-in-jms-header-names |
指定是否应将标头名称中的非法字符发送给 JMS 代理。通常为连字符和句号。 |
attributes-to-send-as-jms-headers-regex |
指定正则表达式，用于确定应作为 JMS 标头发送的 FlowFile 属性的名称 |
代理 |
指向 JMS 消息代理的网络位置的 URI。针对 ActiveMQ 的示例：“tcp://myhost:61616”。针对 IBM MQ 的示例：“myhost(1414)”和“myhost01(1414)，myhost02(1414)”。 |
cf |
JMS ConnectionFactory 实现类的完全限定名称（例如 org.apache.activemq.ActiveMQConnectionFactory）。 |
cflib |
包含其他资源的目录路径（例如 JARs、配置文件等）要添加到类路径（定义为以逗号分隔的值列表）。此类资源通常表示 ConnectionFactory 实现的目标 JMS 客户端库。 |
character-set |
用于构造或解释 TextMessages 的字符集的名称 |
connection.factory.name |
要为连接工厂查找的 JNDI 对象的名称。 |
java.naming.factory.initial |
JNDI Initial Context Factory Class 的完全限定类名称 (java.naming.factory.initial)。 |
java.naming.provider.url |
JNDI 提供程序的 URL，用作 java.naming.provider.url 的值。有关允许的 URL 架构，请参阅其他详细信息文档。 |
java.naming.security.credentials |
通过 JNDI 进行身份验证时要使用的凭据 (java.naming.security.credentials)。 |
java.naming.security.principal |
通过 JNDI 进行身份验证时要使用的主体 (java.naming.security.principal)。 |
message-body-type |
要构造的 JMS 消息正文的类型。 |
naming.factory.libraries |
指定要添加到 ClassPath 的 jar 文件和/或目录，以加载 JNDI/JMS 客户端库。这应该是文件、目录和/或 URLs 的列表（以逗号分隔）。如果指定了一个目录，则将包含该目录中的任何文件，但不会包含子目录（即，它不是递归的）。 |
record-reader |
记录读取器，用于将传入 FlowFile 解析为记录。 |
record-writer |
记录写入器，用于将记录作为 JMS 消息发布之前对其进行序列化。 |
限制¶
所需权限 |
解释 |
|---|---|
引用远程资源 |
客户端库位置可以通过 HTTP 引用资源 |
关系¶
名称 |
描述 |
|---|---|
failure |
无法发送到 JMS 目标的所有 FlowFiles 都会路由到此关系 |
success |
发送到 JMS 目标的所有 FlowFiles 都会路由到此关系 |