Purpose
Defines a message queue as a source of records.Format
/MQINPUT server {queue_extract|query_extract}where
| queue_extract | = | QUEUE queue [ALIAS alias] [FIELDS field [,field...]] [parameters] |
| query_extract | = | QUERY query_text ALIAS alias [parameters] |
| parameters | = | PARAMETERS parameter [,parameter...] |
| parameter | = | parameter_name parameter_value |
Arguments
| server | The server on which the message queue resides. This value must match the name of the server or the server alias specified in the /mqconnection option. |
| queue | The message queue from which the data is extracted. |
| alias |
An alternate name you assign to the message queue, which can be used to reference the queue from other options. When an alias is defined, you can no longer reference the original name directly in your task. The name must adhere to the rules described for an identifier. For a summary of valid naming and formatting conventions for identifiers and constants, see syntax reference in the Connect help. |
| field | The name of the extract field in the message queue, which can be used to reference the field from other options. |
| parameter_name | The name of the parameter |
| parameter_value | The value of the parameter. |
Location
The option may appear anywhere in the task definition.
Notes
Character encoding
If the character encoding is not set when extracting a text column from a message queue, Connect ETL attempts to extract the text column in the queue server’s character encoding. When Connect ETL does not support the queue server’s character encoding, Connect ETL extracts the column in locale encoding. A column extracted in locale encoding could be extracted differently when Connect ETL expands the encoding support in a future release.
To prevent the possibility of output being changed in a future Connect release, define the character encoding for the target or for each extracted text column.
Apache Kafka source
For Apache Kafka sources, query_extract is not supported. The available fields are ‘Key’, ‘Partition’, ‘Message’, and ‘PartitionOffset’; all other fields are ignored.
MapR Streams source
For MapR Streams sources, query_extract is not supported. The available fields are ‘Key’, ‘Partition’, ‘Message’, ‘PartitionOffset’, ‘Timestamp’, and ‘Producer’; all other fields are ignored.