This Property is only considered if the [Header Output Format] Property has a value of "FlowFile Attributes".Header Separator | header.separator | , | | The character that is used to separate key-value for header in String. The value must be only one character.
This Property is only considered if the [Header Output Format] Property has a value of "Comma-Separated String". |
Remove Curly Braces | remove.curly.braces | False | | If true Remove Curly Braces, Curly Braces in the header will be automatically remove.
This Property is only considered if the [Header Output Format] Property has a value of "Comma-Separated String". |
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 received from the AMQP queue are routed to this relationship |
Reads Attributes:
None specified.Writes Attributes:
Name | Description |
---|
amqp$appId | The App ID field from the AMQP Message |
amqp$contentEncoding | The Content Encoding reported by the AMQP Message |
amqp$contentType | The Content Type reported by the AMQP Message |
amqp$headers | The headers present on the AMQP Message. Added only if processor is configured to output this attribute. |
<Header Key Prefix>.<attribute> | Each message header will be inserted with this attribute name, if processor is configured to output headers as attribute |
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 |
amqp$routingKey | The routingKey of the AMQP Message |
amqp$exchange | The exchange from which AMQP Message was received |
State management:
This component does not store state.Restricted:
This component is not restricted.Input requirement:
This component does not allow an incoming relationship.System Resource Considerations:
None specified.