Consuming Messages from IBM Message Queues
Purpose:¶
This application demonstrates how to consume events from IBM Message Queue and publish messages in to a IBM Queue
Prerequisites:¶
- Ensure that there is a running IBM MQ instance.
- Create a queue manager named ESBQManager, Queue named Queue1 and channel named Channel1
- Download com.ibm.mq.allclient_9.0.5.0_1.0.0.jar and javax.jms-api-2.0.1.jar and copy to
/lib directory.
Executing the Sample:¶
- Start the Siddhi application by clicking on 'Run'
- If the Siddhi application starts successfully, the following messages would be shown on the console
- IBMMessageQueueSample.siddhi - Started Successfully!
Testing the Sample:¶
- Simulate single events. For this, click on 'Event Simulator' (double arrows on left tab) -> 'Single Simulation' -> Select 'IBMMessageQueueSample' as 'Siddhi App Name' -> Select 'SweetProductionSinkStream' as 'Stream Name' -> Provide attribute values -> Send
Viewing the Results:¶
See the output on the console.
@App:name("IBMMessageQueueSample")
@App:description('Consume event from IBM Message Queue')
@source(type='ibmmq',
destination.name='Queue1',
host='192.168.56.3',
port='1414',
channel='Channel1',
queue.manager = 'ESBQManager',
username = 'mqm',
password = '1920',
@map(type='xml'))
define stream SweetProductionSourceStream(name string);
@sink(type='ibmmq',
destination.name='Queue1',
host='192.168.56.3',
port='1414',
channel='Channel1',
queue.manager = 'ESBQManager',
username = 'mqm',
password = '1920',
@map(type='xml'))
define stream SweetProductionSinkStream(name string);
@sink(type='log')
define stream logStream(name string);
from SweetProductionSourceStream
select *
insert into logStream;
Top