

API Docs - v1.0.6

Sink

ibmmq (Sink)

IBM MQ Sink allows users to publish messages to an IBM MQ broker

Syntax

@sink(type="ibmmq", destination.name="<STRING>", host="<STRING>", port="<STRING>", channel="<STRING>", queue.manager="<STRING>", username="<STRING>", password="<STRING>", @map(...)))

QUERY PARAMETERS

Name	Description	Default Value	Possible Data Types	Optional	Dynamic
destination.name	Queue name which IBM MQ sink should send events to		STRING	No	No
host	Host address of the MQ server		STRING	No	No
port	Port of the MQ server		STRING	No	No
channel	Channel used to connect to the MQ server		STRING	No	No
queue.manager	Name of the Queue Manager		STRING	No	No
username	User name of the server. If this is not provided, will try to connect without both username and password	null	STRING	Yes	No
password	Password of the server. If this is not provided, will try to connect without both username and password	null	STRING	Yes	No

Examples EXAMPLE 1

@sink(type='ibmmq',destination.name='Queue1',host='192.168.56.3',port='1414',channel='Channel1',queue.manager = 'ESBQManager',password='1920',username='mqm',@map(type='text'))define stream SweetProductionStream(name string, amount double);

This example shows how to connect to an IBM MQ queue and send messages.

Source

ibmmq (Source)

IBM MQ Source allows users to subscribe to a IBM message queue and receive messages. It has the ability to receive Map messages and Text messages.

Syntax

@source(type="ibmmq", destination.name="<STRING>", host="<STRING>", port="<STRING>", channel="<STRING>", queue.manager="<STRING>", username="<STRING>", password="<STRING>", worker.count="<INT>", @map(...)))

QUERY PARAMETERS

Name	Description	Default Value	Possible Data Types	Optional	Dynamic
destination.name	Queue name which IBM MQ Source should subscribe to		STRING	No	No
host	Host address of the IBM MQ server		STRING	No	No
port	Port of the IBM MQ server		STRING	No	No
channel	Channel used to connect to the MQ server		STRING	No	No
queue.manager	Name of the Queue Manager		STRING	No	No
username	User name of the server. If this is not provided, will try to connect without both username and password	null	STRING	Yes	No
password	Password of the server. If this is not provided, will try to connect without both username and password	null	STRING	Yes	No
worker.count	Number of worker threads listening on the given queue. When the multiple workers are enabled event ordering is not preserved.	1	INT	Yes	No

Examples EXAMPLE 1

@source(type='ibmmq',destination.name='Queue1',host='192.168.56.3',port='1414',channel='Channel1',queue.manager = 'ESBQManager',password='1920',username='mqm',@map(type='text'))define stream SweetProductionStream(name string, amount double);

This example shows how to connect to an IBM message queue and receive messages.