WSO2 Complex Event Processor is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.
Complex Event Processor 4.2.0

Expand all   Collapse all
||
Skip to end of metadata
Go to start of metadata

Introduction

This sample demonstrates how to receive incoming custom map events via JMS transport. Custom events are events with custom mappings  that does not adhere to the default event formats. For more information on event formats, see Event Formats.  This sample does not do any processing on the incoming event.  The log event publisher is used to log the received events, and to verify the messages.

Prerequisites

Follow the steps below to set up the prerequisites before starting the configuration.

  1. Set up the prerequisites required for all samples.

  2. Navigate to <ACTIVEMQ_HOME>/bin/ directory, and execute the following command to start the Apache ActiveMQ server:  ./activemq console

    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.

  3. Configure WSO2 CEP by adding relevant libraries to support JMS transport

  4. 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 0010. For instructions, see Starting sample CEP configurations. This sample configuration does the following:

  • Changes the default Axis2 repo from  <CEP_HOME>/repository/deployment/server to <CEP_HOME>/samples/cep/artifacts/0010
  • Creates a stream with id org.wso2.event.sensor.stream:1.0.0.
  • Create and event receiver with name jmsReceiver with custom mapping.
  • Create and event publisher to log the received messages with name jmsLogger.

Executing the sample

  1. Wait until the CEP terminal prompts a message similar as follows.

  2. Open another terminal, go to <CEP_HOME>/samples/cep/producers/jms/ directory, and run the following command:

    ant -DtopicName=topicMap -Dformat=map -Dbroker=activemq -Dsn=0010

    It builds the jms client and publishes the events at  <CEP_HOME>/samples/cep/artifacts/0010/topicMap.csv to the jms receiver endpoint.

  3. You can see the events getting received by CEP by the logs in its console

  • No labels
||