Purpose
To define a message queue as a target of records.
Format
/MQOUTPUT server {queue_load|query_load}where
| queue_load | = | QUEUE queue [disposition] [parameters] FIELDS fieldlist |
| query_load | = | QUERY query_text [parameters] value [,value...] |
| disposition | = | {INSERT } {TRUNCATEANDINSERT} |
| fieldlist | = | msgfield=value [,msgfield=value...] |
| value | = | {fieldname | valuename} |
| 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. |
| parameter_name | The name of the parameter. |
| parameter_value | The value of the parameter. |
| fieldname | The name of the extract field. |
| valuename | The name of the extract value. |
Location
The option may appear anywhere in the task definition.
Notes
To obtain a target record number, create and call a dmexpress target record function.
Apache Kafka target
For Apache Kafka targets, query_load and disposition are not supported. The available fields are ‘Key’, ‘Partition’, and ‘Message’.
MapR Streams target
For MapR Streams targets, query_load and disposition are not supported. The available fields are ‘Key’, ‘Partition’, and ‘Message’.