Configurations
Config
Base configuration for JmsExtension
Parameters
Name | Type | Description | Default Value | Required |
---|---|---|---|---|
Name |
String |
The name of this configuration. With this name can be later referenced. |
x |
|
Encoding |
String |
The encoding of the Message body to consume if the message doesn't communicate it |
|
|
Content Type |
String |
The default content type of the Message body to consume if the message doesn't communicate it |
*/* |
|
Consumer Config |
Configuration parameters for consuming Messages from a JMS Queue or Topic |
|
||
Producer Config |
Configuration parameters for sending Messages to a JMS Queue or Topic |
|
Associated Operations
Associated Sources
Operations
Consume
Operation that allows the user to consume a single Message from a given Destination. extra configurations that are required based on the destination type. and headers as Result#getAttributes
Parameters
Name | Type | Description | Default Value | Required |
---|---|---|---|---|
Configuration |
String |
The name of the configuration to use. |
x |
|
Destination |
String |
the name of the Destination from where the Message should be consumed |
x |
|
Consumer Type |
One of: |
the type of the MessageConsumer that is required for the given destination, along with any |
|
|
Ack Mode |
Enumeration, one of:
|
the ConsumerAckMode that will be configured over the Message and Session |
|
|
Selector |
String |
a custom JMS selector for filtering the messages |
|
|
Content Type |
String |
the Message's content content type |
|
|
Encoding |
String |
the Message's content encoding |
|
|
Maximum Wait |
Number |
maximum time to wait for a message before timing out |
10000 |
|
Maximum Wait Unit |
Enumeration, one of:
|
Time unit to be used in the maximumWaitTime configurations |
MILLISECONDS |
|
Transactional Action |
Enumeration, one of:
|
The type of joining action that operations can take regarding transactions. |
JOIN_IF_POSSIBLE |
|
Target Variable |
String |
The name of a variable on which the operation's output will be placed |
|
Output
Type |
Any |
Attributes Type |
For Configurations.
Throws
-
JMS:CONNECTIVITY
-
JMS:DESTINATION_NOT_FOUND
-
JMS:CONSUMING
-
JMS:ACK
-
JMS:RETRY_EXHAUSTED
-
JMS:TIMEOUT
Publish
Operation that allows the user to send a Message to a JMS Destination
Parameters
Name | Type | Description | Default Value | Required |
---|---|---|---|---|
Configuration |
String |
The name of the configuration to use. |
x |
|
Destination |
String |
the name of the Destination where the Message should be sent |
x |
|
Destination Type |
Enumeration, one of:
|
The type of the Destination |
QUEUE |
|
Transactional Action |
Enumeration, one of:
|
The type of joining action that operations can take regarding transactions. |
JOIN_IF_POSSIBLE |
|
Body |
Any |
The body of the Message |
#[payload] |
|
Jms Type |
String |
The JMSType header of the Message |
|
|
Correlation Id |
String |
The JMSCorrelationID header of the Message |
|
|
Send Content Type |
Boolean |
true if the body type should be sent as a Message property |
true |
|
ContentType |
String |
The content type of the body |
|
|
Send Encoding |
Boolean |
true if the body outboundEncoding should be sent as a Message property |
true |
|
Encoding |
String |
The outboundEncoding of the message's body |
|
|
Reply To |
The JMSReplyTo header information of the Destination where this Message should be replied to |
|
||
User Properties |
Object |
The custom user properties that should be set to this Message |
|
|
JMSX Properties |
The JMSX properties that should be set to this Message |
|
||
Persistent Delivery |
Boolean |
If true; the Message will be sent using the PERSISTENT JMSDeliveryMode |
|
|
Priority |
Number |
The default JMSPriority value to be used when sending the message |
|
|
Time To Live |
Number |
Defines the default time the message will be in the broker before it expires and is discarded |
|
|
Time To Live Unit |
Enumeration, one of:
|
Time unit to be used in the timeToLive configurations |
|
|
Disable Message Id |
Boolean |
If true; the Message will be flagged to avoid generating its MessageID |
|
|
Disable Message Timestamp |
Boolean |
If true; the Message will be flagged to avoid generating its sent Timestamp |
|
|
Delivery Delay |
Number |
Only used by JMS 2.0. Sets the delivery delay to be applied in order to postpone the Message delivery |
|
|
Delivery Delay Unit |
Enumeration, one of:
|
Time unit to be used in the deliveryDelay configurations |
|
For Configurations.
Throws
-
JMS:CONNECTIVITY
-
JMS:PUBLISHING
-
JMS:DESTINATION_NOT_FOUND
-
JMS:ILLEGAL_BODY
-
JMS:RETRY_EXHAUSTED
Publish Consume
Operation that allows the user to send a message to a JMS Destination and waits for a response either to the provided ReplyTo destination or to a temporary Destination created dynamically and headers as Result#getAttributes
Parameters
Name | Type | Description | Default Value | Required |
---|---|---|---|---|
Configuration |
String |
The name of the configuration to use. |
x |
|
Destination |
String |
the name of the Destination where the Message should be sent |
x |
|
Body |
Any |
The body of the Message |
#[payload] |
|
Jms Type |
String |
The JMSType header of the Message |
|
|
Correlation Id |
String |
The JMSCorrelationID header of the Message |
|
|
Send Content Type |
Boolean |
true if the body type should be sent as a Message property |
true |
|
ContentType |
String |
The content type of the body |
|
|
Send Encoding |
Boolean |
true if the body outboundEncoding should be sent as a Message property |
true |
|
Encoding |
String |
The outboundEncoding of the message's body |
|
|
Reply To |
The JMSReplyTo header information of the Destination where this Message should be replied to |
|
||
User Properties |
Object |
The custom user properties that should be set to this Message |
|
|
JMSX Properties |
The JMSX properties that should be set to this Message |
|
||
Persistent Delivery |
Boolean |
If true; the Message will be sent using the PERSISTENT JMSDeliveryMode |
|
|
Priority |
Number |
The default JMSPriority value to be used when sending the message |
|
|
Time To Live |
Number |
Defines the default time the message will be in the broker before it expires and is discarded |
|
|
Time To Live Unit |
Enumeration, one of:
|
Time unit to be used in the timeToLive configurations |
|
|
Disable Message Id |
Boolean |
If true; the Message will be flagged to avoid generating its MessageID |
|
|
Disable Message Timestamp |
Boolean |
If true; the Message will be flagged to avoid generating its sent Timestamp |
|
|
Delivery Delay |
Number |
Only used by JMS 2.0. Sets the delivery delay to be applied in order to postpone the Message delivery |
|
|
Delivery Delay Unit |
Enumeration, one of:
|
Time unit to be used in the deliveryDelay configurations |
|
|
Ack Mode |
Enumeration, one of:
|
The Session ACK mode to use when consuming the message |
|
|
Maximum Wait |
Number |
Maximum time to wait for a message to arrive before timeout |
10000 |
|
Maximum Wait Unit |
Enumeration, one of:
|
Time unit to be used in the maximumWaitTime configuration |
MILLISECONDS |
|
Content Type |
String |
The content type of the message body to be consumed |
|
|
Encoding |
String |
The encoding of the message body to be consumed |
|
|
Target Variable |
String |
The name of a variable on which the operation's output will be placed |
|
Output
Type |
Any |
Attributes Type |
For Configurations.
Throws
-
JMS:CONNECTIVITY
-
JMS:PUBLISHING
-
JMS:DESTINATION_NOT_FOUND
-
JMS:CONSUMING
-
JMS:ILLEGAL_BODY
-
JMS:ACK
-
JMS:RETRY_EXHAUSTED
-
JMS:TIMEOUT
Sources
Listener
JMS Subscriber for Destinations, allows to listen for incoming Messages
Parameters
Name | Type | Description | Default Value | Required |
---|---|---|---|---|
Configuration |
String |
The name of the configuration to use. |
x |
|
Destination |
String |
The name of the Destination from where the Message should be consumed |
x |
|
Consumer Type |
One of: |
The Type of the Consumer that should be used for the provided destination |
|
|
Ack Mode |
Enumeration, one of:
|
The Session ACK mode to use when consuming a message |
|
|
Selector |
String |
JMS selector to be used for filtering incoming messages |
|
|
Inbound Content Type |
String |
The content type of the message body |
|
|
Inbound Encoding |
String |
The inboundEncoding of the message body |
|
|
Synchronous |
Boolean |
This makes the message listener to work synchronously, only one message at a time will be consumed, delivered and waited to be processed in the flow. |
true |
|
Number Of Consumers |
Number |
The number of concurrent consumers that will be used to receive JMS Messages |
4 |
|
Transactional Action |
Enumeration, one of:
|
The type of beginning action that sources can take regarding transactions. |
NONE |
|
Redelivery Policy |
Defines a policy for processing the redelivery of the same message |
|
||
Reconnection Strategy |
A retry strategy in case of connectivity errors |
|
||
Body |
Any |
The body of the Message |
#[payload] |
|
Jms Type |
String |
The JMSType identifier header of the Message |
|
|
Correlation Id |
String |
The JMSCorrelationID header of the Message |
|
|
Send Content Type |
Boolean |
Whether or not the body content type should be sent as a property |
true |
|
ContentType |
String |
The content type of the message's body |
|
|
Send Encoding |
Boolean |
Whether or not the body outboundEncoding should be sent as a Message property |
true |
|
Encoding |
String |
The encoding of the message's body |
|
|
Reply To |
The destination where a reply to this Message should be sent |
|
||
User Properties |
Object |
The custom user properties that should be set to this Message |
|
|
JMSX Properties |
The JMSX properties that should be set to this Message |
|
||
Persistent Delivery |
Boolean |
Whether or not the delivery should be done with a persistent configuration |
|
|
Priority |
Number |
The default JMSPriority value to be used when sending the message |
|
|
Time To Live |
Number |
Defines the default time the message will be in the broker before it expires and is discarded |
|
|
Time To Live Unit |
Enumeration, one of:
|
Time unit to be used in the timeToLive configurations |
|
|
Disable Message Id |
Boolean |
If true; the Message will be flagged to avoid generating its MessageID |
|
|
Disable Message Timestamp |
Boolean |
If true; the Message will be flagged to avoid generating its sent Timestamp |
|
|
Delivery Delay |
Number |
Only used by JMS 2.0. Sets the delivery delay to be applied in order to postpone the Message delivery |
|
|
Delivery Delay Unit |
Enumeration, one of:
|
Time unit to be used in the deliveryDelay configurations |
|
Output
Type |
Any |
Attributes Type |
For Configurations.
Types
Jms Consumer Config
Field | Type | Default Value |
---|---|---|
Ack Mode |
Enumeration, one of:
|
AUTO |
Consumer Type |
One of: |
|
Selector |
String |
|
Max Redelivery |
Number |
0 |
Jms Producer Config
Field | Type | Default Value |
---|---|---|
Persistent Delivery |
Boolean |
true |
Priority |
Number |
4 |
Time To Live |
Number |
0 |
Time To Live Unit |
Enumeration, one of:
|
MILLISECONDS |
Disable Message Id |
Boolean |
false |
Disable Message Timestamp |
Boolean |
false |
Delivery Delay |
Number |
|
Delivery Delay Unit |
Enumeration, one of:
|
MILLISECONDS |
Jms Type |
String |
Redelivery Policy
Field | Type | Default Value |
---|---|---|
Max Redelivery Count |
Number |
|
Use Secure Hash |
Boolean |
|
Message Digest Algorithm |
String |
|
Id Expression |
String |
|
Object Store Ref |
String |
Reconnect
Field | Type | Default Value |
---|---|---|
Frequency |
Number |
|
Count |
Number |
|
Blocking |
Boolean |
Reconnect Forever
Field | Type | Default Value |
---|---|---|
Frequency |
Number |
Jms Destination
Field | Type | Default Value |
---|---|---|
Destination |
String |
|
Destination Type |
Enumeration, one of:
|
QUEUE |
Jmsx Properties
Field | Type | Default Value |
---|---|---|
Jmsx User ID |
String |
|
Jmsx App ID |
String |
|
Jmsx Delivery Count |
Number |
|
Jmsx Group ID |
String |
|
Jmsx Group Seq |
Number |
|
Jmsx Producer TXID |
String |
|
Jmsx Consumer TXID |
String |
|
Jmsx Rcv Timestamp |
Number |
Pooling Profile
Field | Type | Default Value |
---|---|---|
Max Active |
Number |
|
Max Idle |
Number |
|
Max Wait |
Number |
|
Min Eviction Millis |
Number |
|
Eviction Check Interval Millis |
Number |
|
Exhausted Action |
Enumeration, one of:
|
|
Initialisation Policy |
Enumeration, one of:
|
|
Disabled |
Boolean |
Active MQ Connection Factory Configuration
Field | Type | Default Value |
---|---|---|
Broker Url |
String |
vm://localhost?broker.persistent=false&broker.useJmx=false |
Enable Xa |
Boolean |
false |
Initial Redelivery Delay |
Number |
1000 |
Redelivery Delay |
Number |
1000 |
Max Redelivery |
Number |
0 |
Topic Consumer
Field | Type | Default Value |
---|---|---|
Is Durable |
Boolean |
false |
Is Shared |
Boolean |
false |
No Local |
Boolean |
false |
Subscription Name |
String |
Default Caching
Field | Type | Default Value |
---|---|---|
Session Cache Size |
Number |
1 |
Cache Producers |
Boolean |
true |
Cache Consumers |
Boolean |
true |
Jndi Connection Factory
Field | Type | Default Value |
---|---|---|
Connection Factory Jndi Name |
String |
|
Lookup Destination |
Enumeration, one of:
|
NEVER |
Name Resolver Provider |
Jndi Name Resolver Provider
Field | Type | Default Value |
---|---|---|
Custom Jndi Name Resolver |
||
Name Resolver Builder |
Jndi Name Resolver Properties
Field | Type | Default Value |
---|---|---|
Jndi Initial Context Factory |
String |
|
Jndi Provider Url |
String |
|
Provider Properties |
Object |
Simple Jndi Name Resolver
Field | Type | Default Value |
---|---|---|
Context Factory |
Any |
|
Jndi Initial Factory |
String |
|
Jndi Provider Properties |
Object |
|
Jndi Provider Url |
String |
Cached Jndi Name Resolver
Field | Type | Default Value |
---|---|---|
Context Factory |
Any |
|
Jndi Initial Factory |
String |
|
Jndi Provider Properties |
Object |
|
Jndi Provider Url |
String |