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.

All docs This doc
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                 
||
Skip to end of metadata
Go to start of metadata

Introduction

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.

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 transport.

  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 0009. 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/0009.
  • Creates a stream with the ID org.wso2.event.sensor.stream:1.0.0.
  • Creates an event receiver named jmsReceiver.
  • 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=0009

    It builds the JMS client and publishes the events in the  <DAS_HOME>/samples/cep/artifacts/0009/topicMap.csv file to the ActiveMQ brocker which then will be recieved via JMS receiver endpoint.

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

  • No labels