WSO2 Complex Event Processor is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.

Versions Compared


  • This line was added.
  • This line was removed.
  • Formatting was changed.


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

  • Creates a stream with the ID named
  • Creates an event publisher named mqttEventPublisher.
  • Load the events stored in the <CEP_HOME>/samples/cep/artifacts/0066/eventsimulatorfiles/events.csv file to the event simulator.


  1. Navigate to the <CEP_HOME>/samples/cep/consumers/mqtt/ directory, and execute the following Ant command using another tab in the CLI: ant -Durl=tcp://localhost:1883 -Dtopic=sensordata -Dsn=066

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

    This builds the MQTT client which fetches the published events in the <CEP_HOME>/samples/cep/artifacts/0066/eventsimulatorfiles/events.csv file from the eventPublisher endpoint as shown below.
    logs of the MQTT client

  2. Log in to the 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 <CEP_HOME>/samples/cep/artifacts/0066/eventsimulatorfiles/events.csv file to the publisher.
    simulating the sending of events to WSO2 CEP
    You view the JSON events that are published to the CEP server in the logs of the consumer terminal as shown below.