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 WSO2 events via the WSO2Event receiver. WSO2Event receiver is implemented based on Apache Thrift. 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

Set up the prerequisites required for all samples.

Building the sample

Start the WSO2 CEP server with the sample configuration numbered 0007. 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/0007

  • Creates an event stream named org.wso2.event.sensor.stream:1.0.0.

  • Creates an event receiver named wso2eventReceiver.

  • Creates an event publisher named wso2eventLogger to log the received messages.

Executing the sample

Open another tab in the CLI and issue the following ant command from the <CEP_HOME>/samples/cep/producers/wso2-event directory.

ant -DstreamId=org.wso2.event.sensor.stream:1.0.0 -Dsn=0007

This builds the wso2event client and publishes the events at <CEP_HOME>/samples/cep/artifacts/0007/org_wso2_event_sensor_stream_1_0_0.csv to the wso2eventReceiver endpoint. You can view the details of the events that are sent as shown in the log below.

The events received by WSO2 CEP are logged as shown below.

  • No labels
||