...
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 do any processing on process the incoming event. The log events. A log event publisher is used to log the received events, and to verify the messages.
...
Changes the default Axis2 repo from
<CEP_HOME>/repository/deployment/server to <CEP_HOME>/sample/artifacts/0007
Creates a an event stream with id named
org.wso2.event.sensor.stream:1.0.0
.Creates an event receiver with name named
wso2eventReceiver
.Creates an event publisher to named
wso2eventLogger
to log the received messages with namewso2eventLogger
.
Executing the sample
Open another
...
tab in the CLI and issue the following ant
command from the <CEP_HOME>/samples/producers/wso2-event
...
directory.
Code Block | ||
---|---|---|
| ||
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/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.