

Publishing XML Events via RabbitMQ¶

Purpose:¶

This application demonstrates how to configure ESB Streaming Integrator Tooling to send sweet production events via RabbitMQ transport in XML format, and view the output on the rabbitmq-consumer.

Prerequisites:¶

Save this sample. The following message appears on the console.
```
Siddhi App PublishRabbitmqInXmlFormat successfully deployed.
```
Setting up RabbitMQ broker in Ubuntu Linux.
1. To download and install RabbitMQ, run the following commands:
```
sudo apt-get update
sudo apt-get install rabbitmq-server
```
2. To manage the maximum amount of connections upon launch, open and edit the following configuration file using a nano command:
```
sudo nano /etc/default/rabbitmq-server
```
3. To enable RabbitMQ Management Console, run the following command:
```
sudo rabbitmq-plugins enable rabbitmq_management
```
4. To start the service, issue the following command:
```
invoke-rc.d rabbitmq-server start
```

Executing the Sample:¶

Open a terminal and navigate to the {WSO2SIHome}/samples/sample-clients/rabbitmq-consumer directory and run the ant command.
- If you use the default exchange RABBITMQSAMPLE and URI amqp://guest:guest@localhost:5672 in your program use ant command without any arguments.
- However, if you use different exchange names or URIs, run the ant command with appropriate arguments. e.g., ant -Dexchange=rabbitMqtest
Start the Siddhi application by clicking 'Run'.
If the Siddhi application starts successfully, the following messages appear on the console.
```
PublishRabbitmqInXmlFormat.siddhi - Started Successfully!
```

Testing the Sample:¶

Open the event simulator by clicking the second icon or pressing Ctrl+Shift+I.
In the Single Simulation tab of the panel, select values as follows:
- Siddhi App Name: PublishRabbitmqInXmlFormat
- Stream Name: SweetProductiontream
In the name field and amount fields, enter 'toffee' and '45.24' respectively and then click Send to send the event.
Send some more events.

Viewing the Results:¶

See the output in the terminal of {WSO2SIHome}/samples/sample-clients/rabbitmq-consumer. You will get the output as follows (sample output for 4 events):

[java] [org.apache.axiom.om.util.StAXUtils] : XMLStreamReader is org.apache.axiom.util.stax.dialect.SJSXPStreamReaderWrapper
[java] [io.siddhi.core.stream.output.sink.LogSink] : PublishRabbitmqInXmlFormatTest : logStream : Event{timestamp=1512448790922, data=[toffee, 9.78], isExpired=false}
[java] [org.apache.axiom.om.util.StAXUtils] : XMLStreamReader is org.apache.axiom.util.stax.dialect.SJSXPStreamReaderWrapper
[java] [io.siddhi.core.stream.output.sink.LogSink] : PublishRabbitmqInXmlFormatTest : logStream : Event{timestamp=1512448813975, data=[lollipop, 12.6], isExpired=false}
[java] [org.apache.axiom.om.util.StAXUtils] : XMLStreamReader is org.apache.axiom.util.stax.dialect.SJSXPStreamReaderWrapper
[java] [io.siddhi.core.stream.output.sink.LogSink] : PublishRabbitmqInXmlFormatTest : logStream : Event{timestamp=1512448830488, data=[Pop, 72.6], isExpired=false}

Notes:¶

If you need to edit this application while it is running, stop the application -> Save -> Start. If the message 'LowProducitonAlertStream' stream could not connect to 'localhost:5672', it could be due to port 5672, which is defined in the Siddhi application. This port is already being used by a different program. To resolve this issue, please do the following, * Stop this Siddhi application (click 'Run' on menu bar -> 'Stop'). * Change the port 5672 to an unused port. * Start the application and check whether the expected output appears on the console. RabbitMq consumer was written according to this example (go through the RabbitMQReceiver application).

@App:name("PublishRabbitmqInXmlFormat")
@APP:description("demonstrates how to configure ESB Streaming Integrator Tooling to send sweet production events via RabbitMQ transport in XML format, and view the output on the rabbitmq-consumer")

define stream SweetProductionStream (name string, amount double);

@sink(type ='rabbitmq', uri = 'amqp://guest:guest@localhost:5672', exchange.name = 'RABBITMQSAMPLE',
    @map(type='xml'))
define stream LowProducitonAlertStream (name string, amount double);

from SweetProductionStream
select *
insert into LowProducitonAlertStream;

Top