The latest version for DAS is WSO2 Data Analytics Server 3.1.0. View documentation for the latest release.
WSO2 Data Analytics Server is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.
Data Analytics Server 3.1.0

All docs This doc
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 the JMS transport. Custom events are events with custom mappings  that do not adhere to the default event formats. For more information on event formats, see Event Formats. This sample does not process incoming events. 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 general prerequisites required for all samples.

  2. Navigate to the <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, follow the instructions in the Apache ActiveMQ Documentation.

  3. Configure WSO2 DAS by adding the relevant libraries to support JMS transports.

  4. Configure the sample client by adding the relevant jars. For more information, see setting up JMS for JMS sample clients.

Building the sample 

Start the WSO2 DAS 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  <DAS_HOME>/repository/deployment/server to <DAS_HOME>/samples/cep/artifacts/0010.
  • Creates a stream with the ID org.wso2.event.sensor.stream:1.0.0.
  • Creates an event receiver named jmsReceiver with custom mapping.
  • Creates an event publisher named jmsLogger to log the received messages.

Executing the sample

  1. Wait until the DAS terminal prompts a message similar to the following.

  2. Open another terminal and navigate to the <DAS_HOME>/samples/cep/producers/jms/directory. Then run the following command.

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

    It builds the JMS client and publishes the events in the <DAS_HOME>/samples/cep/artifacts/0010/topicMap.csv file to the JMS receiver endpoint.

    The events received by WSO2 DAS are logged in the console as shown below.

  • No labels
||