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:
|
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 | 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, visit 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.