ConsumeAMQP
描述:
使用AMQP 0.9.1的协议来消费AMQP Broker的消息。从AMQP Broker收到的每个消息将作为数据流输出到成功的连线
标签:
amqp, rabbit, get, message, receive, consume, 消息, 接收, 消费
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 orchsym.properties 文件中存在属性设置 orchsym.sensitive.props.key.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 队列 | 将要消费且存在的消息队列名字。通常由AMQP管理员预先设置 | ||
| 自动应答消息 | 否 | - 是 - 否 | 如果设置是，则AMQP Broker将自动确认收到的消息。 这通常会提供更好的吞吐量，但可能会导致重新启动平台后丢失消息。 |
| 分批数量 | 10 | 针对单个会话拉取消息数。 一旦有足够的消息被接收到，或没有可用的消息可接收，则将接收到所有消息输出到成功连线，并应答AMQP Broker的消息。将该参数设置大些，有利于提高效率，尤其是针对非常小的消息, 但是也可能导致比较多的重复消息当平台被重启后 | |
| 主机 | 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队列中接收到的消息将输出到此连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| amqp$appId | AMQP消息的应用ID |
| amqp$contentEncoding | AMQP消息报告的内容编码 |
| amqp$contentType | AMQP消息报告的内容类型 |
| amqp$headers | AMQP消息中的消息头 |
| amqp$deliveryMode | 消息的发送模式 |
| amqp$priority | 消息级别 |
| amqp$correlationId | 消息的相关性ID |
| amqp$replyTo | 消息的“答复”字段的值 |
| amqp$expiration | 消息过期时间 |
| amqp$messageId | 消息的唯一ID |
| amqp$timestamp | 消息的时间戳（毫秒数） |
| amqp$type | 消息类型 |
| amqp$userId | 用户ID |
| amqp$clusterId | AMQP集群ID |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件禁止提供输入流。
系统资源考量:
未提供。