The adapter sends and receives messages via an IBM Websphere MQ (MQ Series) message queue and supports MQ-specific features such as Dynamic Queues.
Properties
|
Delete |
(no function) |
|
File name |
(no function) |
|
I/O Mode |
(no function) |
|
Operation |
Determines which operation is executed with the message queue. Possible values:
|
Parameter
|
alias |
Name of the parameter group for external configuration of the adapter via the |
|
toXML |
If property Operation was set to Possible values:
|
|
ccdtUrl |
URL to a Client Channel Definition Table (CCDT) There are four different ways to define the
The above priority is applied. |
|
RemoteQueueManager.
|
Name of the queue manager Possible values:
|
|
MQEnviroment.hostname |
Hostname of the addressed MQ server; applies system-wide within the entire Java VM for all following operations (the parameter is only needed for local tests on development systems, otherwise leave it empty!) Possible values:
|
|
MQEnviroment.channel |
Name of the channel;applies system-wide within the entire Java VM for all following operations (only needed for local tests on development systems, otherwise leave empty!) Possible values:
|
|
MQEnviroment.CCSID |
CCSID (Charset) of all messages for the entire Java VM; applies system-wide within the entire Java VM for all subsequent operations, therefore use with care (should not be used!) Possible values:
|
|
MQEnviroment.userID |
User ID for authentication of the WebSphere MQ client ; valid system-wide within the whole Java VM for all following operations (only needed for local tests on development systems, otherwise leave empty!) |
|
MQEnviroment.
|
MQ-specific parameter; applies system-wide within the entire Java VM for all following operations (only needed for local tests on development systems, otherwise leave empty!) Possible values:
|
|
MQEnviroment.password |
Password for authentication of the WebSphere MQ client ; valid system-wide within the whole Java VM for all following operations (only needed for local tests on development systems, otherwise leave empty!) Possible values:
|
|
MQEnviroment.port |
Port of the MQServer; applies system-wide within the entire Java VM for all following operations (only needed for local tests on development systems, otherwise empty). Possible values:
|
|
MQEnviroment.
|
Additional information on Possible values: |
|
MQEnviroment.
|
Setting for the current connection Possible values: MQC.TRANSPORT_MQSERIES: Only allowed value |
|
MQEnviroment.
|
CCSID (Charset) for the current connection Possible values: Any integer (e.g. 1208) |
|
MQEnviroment.
|
User ID for the current connection Possible values: Any string |
|
MQEnviroment.
|
Name of the channel for the current connection Possible values: Any string (e.g. MQSR2402.CLS25740.DT) |
|
MQEnviroment.
|
Connection options for the current connection Possible values: Any string |
|
MQEnviroment.
|
Host name of the addressed MQ server for the current connection. Possible values: Any string (e.g. MQSR2402) |
|
MQEnviroment.
|
Local address for the current connection Possible values: Any string |
|
MQEnviroment.
|
ORB property for the current connection Possible values: Any string |
|
MQEnviroment.
|
Password property for the current connection setup to authenticate the WebSphere MQ client (corresponds to parameter MQEnviroment.password). Possible values: Any string |
|
MQEnviroment.
|
Port for the current connection Possible values: Any string |
|
MQEnviroment.
|
Receive Exit property for the current connection Possible values: Any string |
|
MQEnviroment.
|
Security Exit property for the current connection Possible values: Any string |
|
MQEnviroment.
|
Send Exit property for the current connection Possible values: Any string |
|
MQQueueManager.name |
Name of the QueueManager. Only necessary for local tests on development systems, otherwise empty. |
|
MQQueue.name |
Queue name |
|
MQQueue.dynamic
|
Name of the session queue for this message (Should not be used in the future) |
|
MQQueue.alternate
|
Alternative user ID to check access to the queue when it is open; this parameter cannot be set while the object is open |
|
MQQueue.openOptions.
|
(Must be set for write access) |
|
MQQueue.openOptions.
|
Allows the MQ Manager to disconnect the listener (e.g. at shutdown). |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
Apply queue settings for persistence etc. (should always be set) Possible values:
|
|
MQQueue_openOptions.
|
MQ specific parameter |
|
MQQueue_openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
Accept queue settings for persistence etc. (Must always be set when reading) Possible values:
|
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQQueue.openOptions.
|
MQ specific parameter |
|
MQPutMessageOptions.
|
MQ specific parameter |
|
MQPutMessageOptions.
|
Use syncpoint when writing Possible values:
|
|
MQQueue.
|
MQ specific parameter |
|
MQQueue.
|
MQ specific parameter |
|
MQMessage.format |
Message format Possible values:
|
|
MQMessage.
|
MQ specific parameter |
|
MQMessage.
|
MQ specific parameter |
|
MQMessage.
|
MQ specific parameter |
|
MQMessage.
|
MQ specific parameter |
|
MQMessage.
|
Name of the ReplyToQueue for this message |
|
MQMessage.
|
Name of the ReplyToQueueManager for this message Possible values: Any string |
|
MQMessage.
|
Charset (CCSID) for the message; When reading: the expected charset; When writing: the charset that gets the message. Possible values: Any CCSID (e.g. 1208) |
|
MQMessage.
|
CorrelationID with 24 byte length (this is Base64 encoded as well as the returned MessageID). Possible values: Arbitrary string of 32 characters containing a Base64 encoded CorrelationID with 24 bytes length |
|
MQMessage.encoding |
Character encoding of the message |
|
MQMessage.expiry |
Time in tenths of seconds after which the message becomes invalid and is deleted from the queue. Possible values: Any integer |
|
MQMessage.feedback |
MQ specific parameter |
|
MQMessage.groupId |
MQ specific parameter |
|
MQMessage.messageId |
MQ specific parameter |
|
MQMessage.
|
MQ specific parameter |
|
MQMessage.message
|
MQ specific parameter |
|
MQMessage.offset |
MQ specific parameter |
|
MQMessage.
|
MQ specific parameter |
|
MQMessage
|
MQ specific parameter |
|
MQMessage.priority |
MQ specific parameter |
|
MQMessage.
|
MQ specific parameter |
|
MQMessage.report |
MQ specific parameter |
|
MQMessage.userId |
MQ specific parameter |
|
MQGetMessageOptions.
|
Use syncpoint when receiving messages (required for commit and rollback operations). Possible values:
|
|
MQGetMessageOptions.
|
Wait during readout if there is no message in the queue |
|
MQGetMessageOptions.
|
When reading out, do not wait if there is no message in the queue and cancel immediately Possible values:
|
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
Enable automatic conversion to MQ Possible values:
|
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
Ignore all other GetOptions Possible values:
|
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
Deactivate Syncpoint Possible values:
|
|
MQGetMessageOptions.
|
Use Syncpoint if the message is marked as persistent Possible values:
|
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
MQ specific parameter |
|
MQGetMessageOptions.
|
Time in milliseconds to wait during readout if there are no messages in the queue (see parameter MQGetMessageOptions.options.MQC.MQGMO_WAIT). Message reception is not aborted if it was started during the wait interval. Possible values: Any positive integer |
|
MQGetMessageOptions.
|
MQ specific parameterMQ specific parameter |
For more information on MQ-specific parameters, visit https://www.ibm.com/docs/en/ibm-mq/8.0?topic=java-mqenvironment.
Status values
|
|
The operation was executed successfully. |
|
|
The operation was executed successfully, but without any result. |
|
|
The operation failed due to a technical error. |
Example
The generated XML document when Operation property is set to Receive has the following structure:
<document>
<header>
<CorrelationID>AAAAAAAAAAAAAAAAAAAAA</CorrelationID>
<MessageID>QU1RIFFNX3NwX2Nvbm5lYxvAdUQgC9sH</MessageID>
<MessageSequenceNr>1</MessageSequenceNr>
<MessageFormat>MQSTR</MessageFormat>
<ReplyToQueue/>
<ReplyToQueueMngr>QM_sp_connect</ReplyToQueueMngr>
<backoutCount>0</backoutCount>
</header>
<body>Message</body>
</document>
For more information about the MQ Series specific parameters, please refer to its vendor IBM's documentation WebSphere MQ - Using Java in Chapter 9 The WebSphere MQ base Java classes and interfaces.