PublishAMQP
描述:
将输入数据流的内容作为AMQP消息发送到AMQP Exchange。典型的AMQP模式， 基于消息路由键来发送AMQP路由消息队列。如果由于Exchange、路由键和队列的未绑定设置，则消息将没有目标而返回(比如, 数据不进入队列)，如果发生这种情况，将在应用日志和公告中看到相应的日志信息，然后数据流将输出到'失败' 连线
标签:
amqp, rabbit, put, message, send, publish, 发送, 发布, 消息
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 orchsym.properties 文件中存在属性设置 orchsym.sensitive.props.key.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| Exchange名字 | 将消息发布到AMQP Exchange的名字。通常由AMQP管理员预先设置 (比如 'amq.direct'). 且为可选设置。如果置空，则消息将发送到默认的AMQP Exchange 支持表达式语言 (支持流属性和变量) | ||
| 路由键 | 指定用于AMQP路由消息队列的消息路由键的名字。通常由AMQP管理员预先设置 (比如 'myKey')。当消息发送到默认的AMQP Exchange时，该属性指定目标队列的名字。否则必须提供路由键设置，用于绑定到AMQP Exchange的队列 (通常是管理员来绑定) 支持表达式语言 (支持流属性和变量) | ||
| 主机 | localhost | AMQP Broker的网络地址 (比如：localhost) 支持表达式语言 (仅支持变量) | |
| 端口 | 5672 | AMQP Broker访问的端口号 (比如： 5671) 支持表达式语言 (仅支持变量) | |
| 虚拟主机 | 隔离AMQP系统以增强安全性的虚拟主机名 支持表达式语言 (仅支持变量) | ||
| 用户名 | guest | 用于认证和授权的访问用户名 支持表达式语言 (仅支持变量) | |
| 密码 | guest | 用于认证和授权的访问用户名密码 敏感状态 支持表达式语言 (仅支持变量) | |
| AMQP版本号 | 0.9.1 | - 0.9.1 | 支持的AMQP版本号. 目前支持 v0.9.1 |
| SSL服务 | 控制器服务API: SSLContextService 实现: StandardRestrictedSSLContextService StandardSSLContextService | 提供客户端认证信息的TLS/SSL连接服务 | |
| 证书身份认证 | 不使用 | - 使用 - 不使用 | 使用SSL证书来认证客户端来代替用户名和密码 |
| 客户端认证 | 必须 | - 请求 - 必须 - 不需要 | 设置安全连接(TLS/SSL)到AMQP Broker的客户端授权策略。该参数仅当SSL服务被设置并激活才有效 |
连线:
| 名字 | 描述 |
|---|---|
| success | 所有成功发送到AMQP目标的消息将输出到此连线 |
| failure | 所有不能发送到AMQPP目标的消息将输出到此连线 |
读取属性:
| 名字 | 描述 |
|---|---|
| amqp$appId | The App ID field to set on the AMQP Message |
| amqp$contentEncoding | The Content Encoding to set on the AMQP Message |
| amqp$contentType | The Content Type to set on the AMQP Message |
| amqp$headers | The headers to set on the AMQP Message |
| amqp$deliveryMode | The numeric indicator for the Message's Delivery Mode |
| amqp$priority | The Message priority |
| amqp$correlationId | The Message's Correlation ID |
| amqp$replyTo | The value of the Message's Reply-To field |
| amqp$expiration | The Message Expiration |
| amqp$messageId | The unique ID of the Message |
| amqp$timestamp | The timestamp of the Message, as the number of milliseconds since epoch |
| amqp$type | The type of message |
| amqp$userId | The ID of the user |
| amqp$clusterId | The ID of the AMQP Cluster |
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
| 资源 | 描述 |
|---|---|
| MEMORY | 该组件可能导致平台及系统资源的高使用率，多个实例或高并发性设置可能导致性能下降。 |