JmsConnector is a JMS 1.0.2b, 1.1 and 2.0 compliant MuleSoft Extension, used to consume and produce JMS Messages. The Extension supports all JMS functionality including topics and queues, durable subscribers, acknowledgement modes and local transactions.
Configurations
Config
Base configuration for JmsConnector
Parameters
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Name |
String |
The name for this configuration. Connectors reference the configuration with this name. |
x |
|
Content Type |
String |
The default contentType of the Message body to be used if the message doesn't communicate it |
*/* |
|
Ack Mode |
Enumeration, one of:
|
The ConsumerAckMode to use when consuming a Message Can be overridden at the message source level. This attribute has to be IMMEDIATE if transactionType is LOCAL or MULTI |
AUTO |
|
Consumer Type |
One of: |
The ConsumerType to be used by default when consuming a Message Can be overridden at the message source level. |
|
|
Selector |
String |
Default selector to be used for filtering when consuming a Message Can be overridden at the message source level. |
|
|
Max Redelivery |
Number |
Used to configure the number of redelivers before discarding the message. No redelivery is represented with 0, while -1 means infinite re deliveries accepted. |
0 |
|
Persistent Delivery |
Boolean |
Sets the default value for the Message#getJMSDeliveryMode. If true, the DeliveryMode#PERSISTENT mode will be used, which instructs the JMS provider to take extra care to insure the message is not lost in transit due to a JMS provider failure. |
true |
|
Priority |
Number |
Defines the default Message#getJMSPriority to use when sending messages |
4 |
|
Time To Live |
Number |
Defines the default time the message will be in the broker before it expires and is discarded |
0 |
|
Time To Live Unit |
Enumeration, one of:
|
A TimeUnit which qualifies the #timeToLive attribute. Defaults to MILLISECONDS |
MILLISECONDS |
|
Disable Message Id |
Boolean |
Defines the default value to use when producing messages, for disabling the Message#getJMSMessageID generation in the broker. Depending on the provider it may or may not have effect |
false |
|
Disable Message Timestamp |
Boolean |
Defines the default value to use, when producing messages, for disable Message#getJMSTimestamp generation in the broker. Depending on the provider it may or may not have effect. |
false |
|
Delivery Delay |
Number |
This is used to determine the Message delivery delay time which is calculated by adding the deliveryDelay value specified on the send method to the time the message was sent. Only used in JmsSpecification#JMS_2_0 |
|
|
Delivery Delay Unit |
Enumeration, one of:
|
A TimeUnit which qualifies the #deliveryDelay attribute. Defaults to MILLISECONDS |
MILLISECONDS |
|
Jms Type |
String |
A message JMSType identifier supplied by a client when a message is sent. |
|
Associated Operations
Associated Sources
Operations
Consume
<jms: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 |
|
|
Target Value |
String |
An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable |
#[payload] |
|
Reconnection Strategy |
A retry strategy in case of connectivity errors |
|
Output
Type |
Any |
Attributes Type |
For Configurations.
Throws
-
JMS:TIMEOUT
-
JMS:CONNECTIVITY
-
JMS:CONSUMING
-
JMS:SECURITY
-
JMS:RETRY_EXHAUSTED
-
JMS:DESTINATION_NOT_FOUND
-
JMS:ACK
Publish
<jms: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 |
|
|
Reconnection Strategy |
A retry strategy in case of connectivity errors |
|
For Configurations.
Throws
-
JMS:PUBLISHING
-
JMS:CONNECTIVITY
-
JMS:SECURITY
-
JMS:ILLEGAL_BODY
-
JMS:RETRY_EXHAUSTED
-
JMS:DESTINATION_NOT_FOUND
Publish Consume
<jms: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 |
|
|
Target Value |
String |
An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable |
#[payload] |
|
Reconnection Strategy |
A retry strategy in case of connectivity errors |
|
Output
Type |
Any |
Attributes Type |
For Configurations.
Throws
-
JMS:PUBLISHING
-
JMS:TIMEOUT
-
JMS:CONNECTIVITY
-
JMS:CONSUMING
-
JMS:SECURITY
-
JMS:ILLEGAL_BODY
-
JMS:RETRY_EXHAUSTED
-
JMS:DESTINATION_NOT_FOUND
-
JMS:ACK
Ack
<jms:ack>
Allows the user to perform an ACK when the AckMode#MANUAL mode is elected while consuming the Message. As per JMS Spec, performing an ACK over a single Message automatically works as an ACK for all the Messages produced in the same JmsSession. to a session of the current connection
Parameters
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Ack Id |
String |
The AckId of the Message to ACK |
x |
Throws
-
JMS:ACK
Recover Session
<jms:recover-session>
Allows the user to perform a session recover when the AckMode#MANUAL mode is elected while consuming the Message. As per JMS Spec, performing a session recover automatically will redeliver all the consumed messages that had not being acknowledged before this recover.
Parameters
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Ack Id |
String |
The AckId of the Message Session to recover |
x |
Throws
-
JMS:SESSION_RECOVER
Sources
Listener
<jms: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 |
|
|
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 |
|
Transaction Type |
Enumeration, one of:
|
The type of transaction to create. Availability will depend on the runtime version. |
LOCAL |
|
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
Redelivery Policy
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Redelivery Count |
Number |
The maximum number of times a message can be redelivered and processed unsuccessfully before triggering process-failed-message |
||
Use Secure Hash |
Boolean |
Whether to use a secure hash algorithm to identify a redelivered message |
||
Message Digest Algorithm |
String |
The secure hashing algorithm to use. If not set, the default is SHA-256. |
||
Id Expression |
String |
Defines one or more expressions to use to determine when a message has been redelivered. This property may only be set if useSecureHash is false. |
||
Object Store |
The object store where the redelivery counter for each message is going to be stored. |
Reconnect
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency |
Number |
How often (in ms) to reconnect |
||
Count |
Number |
How many reconnection attempts to make |
Reconnect Forever
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency |
Number |
How often (in ms) to reconnect |
Jms Destination
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Destination |
String |
x |
||
Destination Type |
Enumeration, one of:
|
QUEUE |
Jmsx Properties
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
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 |
Reconnection
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Fails Deployment |
Boolean |
When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment will fail if the test doesn’t pass after exhausting the associated reconnection strategy |
||
Reconnection Strategy |
The reconnection strategy to use |
Active MQ Connection Factory Configuration
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
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 | Description | Default Value | Required |
|---|---|---|---|---|
Durable |
Boolean |
false |
||
Shared |
Boolean |
false |
||
No Local |
Boolean |
false |
||
Subscription Name |
String |
Default Caching
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Session Cache Size |
Number |
|||
Cache Producers |
Boolean |
true |
||
Cache Consumers |
Boolean |
true |
Jndi Connection Factory
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Factory Jndi Name |
String |
x |
||
Lookup Destination |
Enumeration, one of:
|
NEVER |
||
Name Resolver Provider |
x |
Jndi Name Resolver Provider
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Custom Jndi Name Resolver |
||||
Name Resolver Builder |
Jndi Name Resolver Properties
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Jndi Initial Context Factory |
String |
x |
||
Jndi Provider Url |
String |
|||
Provider Properties |
Object |
Simple Jndi Name Resolver
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Context Factory |
Any |
|||
Jndi Initial Factory |
String |
|||
Jndi Provider Properties |
Object |
|||
Jndi Provider Url |
String |
Cached Jndi Name Resolver
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Context Factory |
Any |
|||
Jndi Initial Factory |
String |
|||
Jndi Provider Properties |
Object |
|||
Jndi Provider Url |
String |