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


This sample demonstrates how to publish WSO2 events via Thrift transport to a WSO2 Event client. This sample does not do any processing on the outgoing events. Events are generated using an input event file and the event simulator.


Set up the prerequisites required for all samples.

Building the sample 

Start the WSO2 DAS server with the sample configuration numbered 0057. For instructions, see Starting sample CEP configurations.

This sample configuration creates the following.

  • A stream with the ID
  • An event publisher named eventPublisher.
  • Loads the events that are stored in the events.csv file via the Event Simulator.

Executing the sample

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=0057

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 a client that fetches the the published events in the <DAS_HOME>/samples/cep/artifacts/0057/eventsimulatorfiles/events.csv file from the emailPublisher endpoint.

Go to the Event Simulator and click Play to send events stored in the events.csv file.


Received events re logged in the Wso2Event client terminal console as shown below.

  • No labels