MQ Series Transfer
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:
|
Parameters
| 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 | 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. localAddressSetting | 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. properties.MQC.SSL_ CIPHER_SUITE_PROPERTY |
Note: Additional information on Possible values: |
| MQEnviroment. properties.MQC. TRANSPORT_PROPERTY | Setting for the current connection Possible values: MQC.TRANSPORT_MQSERIES: Only allowed value |
| MQEnviroment. properties.MQC. CCSID_PROPERTY | CCSID (Charset) for the current connection Possible values: Any integer (e.g. 1208) |
| MQEnviroment. properties.MQC. USER_ID_PROPERTY | User ID for the current connection Possible values: Any string |
| MQEnviroment. properties.MQC. CHANNEL_PROPERTY | Name of the channel for the current connection Possible values: Any string (e.g. MQSR2402.CLS25740.DT) |
| MQEnviroment. properties.MQC. CONNECT_ OPTIONS_ PROPERTY | Connection options for the current connection Possible values: Any string |
| MQEnviroment. properties.MQC. HOST_NAME_PROPERTY | Host name of the addressed MQ server for the current connection. Possible values: Any string (e.g. MQSR2402) |
| MQEnviroment. properties.MQC. LOCAL_ADDRESS_ PROPERTY | Local address for the current connection Possible values: Any string |
| MQEnviroment. properties.MQC. ORB_PROPERTY | ORB property for the current connection Possible values: Any string |
| MQEnviroment. properties.MQC. PASSWORD_PROPERTY | Password property for the current connection setup to authenticate the WebSphere MQ client (corresponds to parameter MQEnviroment.password). Possible values: Any string |
| MQEnviroment. properties.MQC. PORT_PROPERTY | Port for the current connection Possible values: Any string |
| MQEnviroment. properties.MQC. RECEIVE_EXIT_ PROPERTY | Receive Exit property for the current connection Possible values: Any string |
| MQEnviroment. properties.MQC. SECURITY_EXIT_ PROPERTY | Security Exit property for the current connection Possible values: Any string |
| MQEnviroment. properties.MQC. SEND_EXIT_PROPERTY | 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 QueueName | Name of the session queue for this message (Should not be used in the future) |
| MQQueue.alternate UserId | 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. MQC.MQOO_OUTPUT | (Must be set for write access) |
| MQQueue.openOptions. MQC.MQOO_FAIL_ IF_QUIESCING | Allows the MQ Manager to disconnect the listener (e.g. at shutdown). |
| MQQueue.openOptions. MQC.MQDL_SUPPORTED | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_ALTERNATE_ USER_AUTHORITY | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_ BIND_AS_ QDEF | Apply queue settings for persistence etc. (should always be set) Possible values:
|
| MQQueue_openOptions. MQC.MQOO_BIND_ NOT_FIXED | MQ specific parameter |
| MQQueue_openOptions. MQC.MQOO_BIND_ON_ OPEN | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_INPUT_AS_ Q_DEF | Accept queue settings for persistence etc. (Must always be set when reading) Possible values:
|
| MQQueue.openOptions. MQC.MQOO_INPUT_SHARED | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_INPUT_ EXCLUSIVE | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_INQUIRE | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_PASS_ALL_ CONTEXT | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_PASS_ IDENTITY_CONTEXT | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_SAVE_ALL_ CONTEXT | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_SET | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_SET_ALL_ CONTEXT | MQ specific parameter |
| MQQueue.openOptions. MQC.MQOO_SET_ IDENTITY_CONTEXT | MQ specific parameter |
| MQPutMessageOptions. options.MQC.MQPMO_ NEW_MSG_ID | MQ specific parameter |
| MQPutMessageOptions. options.MQC. MQPMO_SYNCPOINT | Use syncpoint when writing Possible values:
|
| MQQueue. closeOptions.MQC. MQCOO_DELETE | MQ specific parameter |
| MQQueue. closeOptions.MQC. MQCOO_DELETE_ PURGE | MQ specific parameter |
| MQMessage.format | Message format Possible values:
|
| MQMessage. applicationIdData | MQ specific parameter |
| MQMessage. application OriginData | MQ specific parameter |
| MQMessage. backoutCount | MQ specific parameter |
| MQMessage. messageFlags.MQC. MQMT_REQUEST | MQ specific parameter |
| MQMessage. replyToQueueName | Name of the ReplyToQueue for this message |
| MQMessage. replyToQueueManager Name | Name of the ReplyToQueueManager for this message Possible values: Any string |
| MQMessage. characterSet | 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 | 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. messageSequence Number | MQ specific parameter |
| MQMessage.message Type | MQ specific parameter |
| MQMessage.offset | MQ specific parameter |
| MQMessage. originalLength | MQ specific parameter |
| MQMessage .persistence | MQ specific parameter |
| MQMessage.priority | MQ specific parameter |
| MQMessage. putApplicationType | MQ specific parameter |
| MQMessage.report | MQ specific parameter |
| MQMessage.userId | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_SYNCPOINT | Use syncpoint when receiving messages (required for commit and rollback operations). Possible values:
|
| MQGetMessageOptions. options.MQC. MQGMO_WAIT | Wait during readout if there is no message in the queue |
| MQGetMessageOptions. options.MQC. MQGMO_NO_WAIT | When reading out, do not wait if there is no message in the queue and cancel immediately Possible values:
|
| MQGetMessageOptions. options.MQC. MQGMO_ACCEPT_ TRUNCATED_MSG | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_BROWSE_FIRST | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_BROWSE_MSG _UNDER_CURSOR | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_BROWSE_NEXT | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_CONVERT | Enable automatic conversion to MQ Possible values:
|
| MQGetMessageOptions. options.MQC.MQGMO_ FAIL_IF_QUIESCING | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_LOCK | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_MSG_UNDER_ CURSOR | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_NONE | Ignore all other GetOptions Possible values:
|
MQGetMessageOptions. | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_NO_SYNCPOINT | Deactivate Syncpoint Possible values:
|
| MQGetMessageOptions. options.MQC.MQGMO_ SYNCPOINT_IF_ PERSISTENT | Use Syncpoint if the message is marked as persistent Possible values:
|
| MQGetMessageOptions. options.MQC.MQGMO_ UNLOCK | MQ specific parameter |
MQGetMessageOptions. | MQ specific parameter |
MQGetMessageOptions. | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_COMPLETE_MSG | MQ specific parameter |
| MQGetMessageOptions. options.MQC. MQGMO_LOGICAL_ORDER | MQ specific parameter |
| MQGetMessageOptions. matchOptions.MQC. MQGMO_MATCH_ CORREL_ID | MQ specific parameter |
| MQGetMessageOptions. matchOptions.MQC. MQGMO_MATCHGROUP_ID | MQ specific parameter |
| MQGetMessageOptions. matchOptions.MQC. MQGMO_MATCH_MSG_ID | 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. resolvedQueueName | MQ specific parameterMQ specific parameter |
For more information on MQ-specific parameters, see https://www.ibm.com/docs/en/ibm-mq/8.0?topic=java-mqenvironment.
Status values
1 | The operation was executed successfully. |
0 | The operation was executed successfully, but without any result. |
-1 | 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.