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 publish custom WSO2 events via WSO2Event 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 outgoing event. Events are generated using an input event file and the event simulator.

Prerequisites

Set up the prerequisites required for all samples. 

Building the sample 

Start the WSO2 DAS server with the sample configuration numbered 0058. For instructions, see Starting sample CEP configurations. This sample configuration does the following.

  • Creates a stream with the ID org.wso2.event.sensor.stream.map:1.0.0.
  • Creates an event publisher named eventPublisher.
  • Loads the events stored in the <DAS_HOME>/samples/cep/artifacts/0058/eventsimulatorfiles/events.csv file to the Event Simulator.

Executing the sample

Follow the steps below to execute the sample.

  1. Navigate to the <DAS_HOME>/samples/cep/consumers/wso2-event/ directory, and execute the following Ant command using another tab in the CLI: ant -Dsn=0058

    The other optional parameters that can be used in the above command are defined in the <DAS_HOME>/samples/cep/consumers/wso2-event/build.xml file.

    This builds the WSO2Event client that fetches the published events in the <DAS_HOME>/samples/cep/artifacts/0058/eventsimulatorfiles/events.csv file from the eventPublisher endpoint as shown below.

    output logs of the consumer

  2. Log into the DAS Management Console.
  3. Click Tools, and then click Event Simulator.
  4. Click Play on the corresponding event stream as shown below, to send the events in the <DAS_HOME>/samples/cep/artifacts/0058/eventsimulatorfiles/events.csv file to the publisher.
    simulating the sending of events to WSO2 CEP
    The WSO2 events that are published to the DAS server are logged in the consumer terminal as shown below.
    output logs of the published events in the consumer terminal
  • No labels
||