Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)Routing Key | Routing Key | | | The name of the Routing Key that will be used by AMQP to route messages from the exchange to a destination queue(s). Usually provided by the administrator (e.g., 'myKey')In the event when messages are sent to a default exchange this property corresponds to a destination queue name, otherwise a binding from the Exchange to a Queue via Routing Key must be set (usually by the AMQP administrator) Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
Header Separator | header.separator | , | | The character that is used to split key-value for headers. The value must only one character. Otherwise you will get an error message |
Brokers | Brokers | | | A comma-separated list of known AMQP Brokers in the format <host>:<port> (e.g., localhost:5672). If this is set, Host Name and Port are ignored. Only include hosts from the same AMQP cluster. Supports Expression Language: true (will be evaluated using variable registry only) |
Host Name | Host Name | localhost | | Network address of AMQP broker (e.g., localhost). If Brokers is set, then this property is ignored. Supports Expression Language: true (will be evaluated using variable registry only) |
Port | Port | 5672 | | Numeric value identifying Port of AMQP broker (e.g., 5671). If Brokers is set, then this property is ignored. Supports Expression Language: true (will be evaluated using variable registry only) |
Virtual Host | Virtual Host | | | Virtual Host name which segregates AMQP system for enhanced security. Supports Expression Language: true (will be evaluated using variable registry only) |
User Name | User Name | | | User Name used for authentication and authorization. Supports Expression Language: true (will be evaluated using variable registry only) |
Password | Password | | | Password used for authentication and authorization. Sensitive Property: true |
AMQP Version | AMQP Version | 0.9.1 | | AMQP Version. Currently only supports AMQP v0.9.1. |
SSL Context Service | ssl-context-service | | Controller Service API: SSLContextService Implementations: StandardSSLContextService StandardRestrictedSSLContextService | The SSL Context Service used to provide client certificate information for TLS/SSL connections. |
Use Client Certificate Authentication | cert-authentication | false | | Authenticate using the SSL certificate rather than user name/password. |
Client Auth | ssl-client-auth | NONE | | The property has no effect and therefore deprecated. |
Relationships:
Name | Description |
---|
success | All FlowFiles that are sent to the AMQP destination are routed to this relationship |
failure | All FlowFiles that cannot be routed to the AMQP destination are routed to this relationship |
Reads Attributes:
Name | Description |
---|
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 |
Writes Attributes:
None specified.State management:
This component does not store state.Restricted:
This component is not restricted.Input requirement:
This component requires an incoming relationship.System Resource Considerations:
Resource | Description |
---|
MEMORY | An instance of this component can cause high usage of this system resource. Multiple instances or high concurrency settings may result a degradation of performance. |