Description:
This processor pulls messages from a JMS Topic, creating a FlowFile for each JMS message or bundle of messages, as configured.
Properties:
In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. If a property has a default value, it is indicated. If a property supports the use of the NiFi Expression Language (or simply, "expression language"), that is also indicated.
- JMS Provider
- This property specifies the provider used for the JMS server. Available options include:
- Supports expression language: false
- URL
- The URL of the JMS server.
- Default value: no default
- Supports expression language: false
- Destination Name
- The name of the JMS topic to use.
- Default value: no default
- Supports expression language: false
- Communications Timeout
- The amount of time to wait when attempting to receive a message before giving up and assuming failure.
- Default value: 30 sec
- Supports expression language: false
- Message Batch Size
- The number of messages to pull in a single iteration of the processor.
- Default value: 10
- Supports expression language: false
- Username
- The username used for authentication and authorization.
- Default value: no default
- Supports expression language: false
- Password
- The password used for authentication and authorization.
- Default value: no default
- Supports expression language: false
- Acknowledgement Mode
- The JMS acknowledgement Mode. Two options exist: Client Acknowledge and Auto Acknowledge. Using Auto Acknowledge can cause messages to be lost upon a restart of NiFi but may provide better performance than Client Acknowledge.
- Default value: Client Acknowledge
- Supports expression language: false
- Message Selector
- The JMS Message Selector to use in order to narrow the messages that are pulled.
- Default value: no default
- Supports expression language: false
- Copy of JMS Properties Attributes
- A Boolean value (true/false), indicating whether the JMS Message Properties should be copied to the FlowFile attributes; if so, each attribute name will be jms.XXX, where XXX is the JMS Property name.
- Default value: true
- Supports expression language: false
- Client ID Prefix
- A human-readable ID that can be used to associate connections with yourself so that the maintainers of the JMS server know who to contact if problems arise.
- Default value: no default
- Supports expression language: false
- Use Durable Subscription
- A Boolean value (true/false), indicating whether connections to the specified topic will use Durable Subscription so that messages are queued when NiFi is not pulling them.
- Default value: false
- Supports expression language: false
Relationships:
- success
- All incoming FlowFiles follow this relationship.