This sample demonstrates how to receive incoming map events that adhere to the WSO2 Event format via the JMS transport. This sample does not process the incoming events. A log event publisher is used to log the received events, and to verify the messages.
Follow the steps below to set up the prerequisites before starting the configuration.
<ACTIVEMQ_HOME>/bin/directory, and execute the following command to start the Apache ActiveMQ server:
This guide uses ActiveMQ versions 5.7.0 - 5.9.0. If you want to use a later version, for instructions on the necessary changes to the configuration steps, go to Apache ActiveMQ Documentation.
Configure WSO2 CEP by adding relevant libraries to support JMS transport
Configure sample client by adding relevant jars. See setting up JMS for JMS sample clients.
Building the sample
Start the WSO2 CEP server with the sample configuration numbered 0009. For instructions, see Starting sample CEP configurations. This sample configuration does the following:
- Changes the default Axis2 repo from
- Creates a stream with id org.wso2.event.sensor.stream:1.0.0.
- Creates an event receiver with name jmsReceiver.
- Creates an event publisher to log the received messages with name jmsLogger.
Executing the sample
Wait until the CEP terminal prompts a message similar as follows.
Open another terminal, go to
and run the following command:
ant -DtopicName=topicMap -Dformat=map -Dbroker=activemq -Dsn=0009
It builds the jms client and publishes the events at
<CEP_HOME>/samples/cep/artifacts/0009/topicMap.csvto the jms receiver endpoint.
You can see the events getting received by CEP by the logs in its console