This documentation is for WSO2 Complex Event Processor 4.0.0. View documentation for the latest release.
WSO2 Complex Event Processor is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.
||
Skip to end of metadata
Go to start of metadata

WSO2 CEP samples explain different use cases of the product using sample clients (producers and consumers). The general flow of all samples is as follows.

  1. Each sample starts WSO2 CEP with a different configuration.
  2. After WSO2 CEP starts, the sample producers send different types of events to the CEP over different transports.
  3. The CEP receives these events and processes them.
  4. Finally it pushes different types of notification events based on the processed data to the sample consumers over different transports.

This section includes a set of samples, demonstrating use cases of WSO2 CEP.

The following table summarizes the producer/consumer clients and the mapping types of each WSO2 CEP sample. For instructions to set up the samples, see Setting up CEP Samples.

Samples on receiving events

Sample no.Producer (publish topic)Event receiver typeReceiver message formatEvent publisher typePublisher message formatConsumer (subscription topic)
0001httpHTTPJSONloggertextNone
0002httpHTTPJSON (custom)loggertextNone
0003httpHTTPXMLloggertextNone
0004httpHTTPXML (custom)loggertextNone
0005httpHTTPtextloggertextNone
0006httpHTTPtext (custom)loggertextNone
0007wso2eventWSO2EventWSO2EventloggertextNone
0008wso2eventWSO2EventWSO2Event (custom)loggertextNone
0009jmsJMS (Active MQ)maploggertextNone
0010jmsJMS (Active MQ)map (custom)loggertextNone
0011jmsJMS (Active MQ)JSON/text/XMLloggertextNone
0012jmsJMS (Qpid)map/XMLloggertextNone
0013jmsJMS (WSO2 MB)map/textloggertextNone
0014soapSOAPXMLloggertextNone
0015NoneEmailtextloggertextNone
0016mqttMQTTJSONloggertextNone
0017filefile-tailtext (custom)loggertextNone
0018kafkakafkaJSONloggertextNone
0019websocketwebsocketJSONloggertextNone
0020NoneWebSocket localJSONloggertextNone
0021jmsJMS (ActiveMQ)maploggertextNone
0022filefile-tailtext (custom)loggertextNone

Samples on processing events

Sample no.Producer (publish topic)Event receiver typeReceiver message formatEvent publisher typePublisher message formatConsumer (subscription topic)
0101wso2-eventWSO2EventWSO2EventloggertextNone
0102None(Event Simulator)NoneloggertextNone
0103None(Event Simulator)NoneloggertextNone
0104None(Event Simulator)NoneloggertextNone
0105None(Event Simulator)NoneloggertextNone
0106None(Event Simulator)NoneloggertextNone
0107None(Event Simulator)NoneloggertextNone
0108None(Event Simulator)NoneloggertextNone
0109None(Event Simulator)NoneloggertextNone
0110None(Event Simulator)NoneloggertextNone
0111httpHTTPtextloggertextNone
0112wso2-eventWSO2EventWSO2EventloggerJSONNone
0113httpHTTPXMLloggertextNone
0114wso2-eventWSO2EventWSO2EventloggertextNone
0115httpHTTPXMLloggerJSONNone
0116None(Event Simulator)NoneloggertextNone
0117filefile-tailtextloggertextNone
0301None(Event Simulator)NoneloggertextNone
0501wso2-eventWSO2EventWSO2EventWSO2EventWSO2Eventwso2-event
0502httpHTTPXMLloggertextNone
0503httpHTTPXMLloggertextNone
0504wso2-eventWSO2EventWSO2EventloggertextNone
1001httpHTTPJSONwebsocket-localJSONNone

Samples on publishing events

Sample no.Producer (publish topic)Event receiver typeReceiver message formatEvent publisher typePublisher message formatConsumer (subscription topic)
0051NoneNoneNoneloggerJSONNone
0052NoneNoneNoneloggerJSON (custom)None
0053NoneNoneNoneloggerXMLNone
0054NoneNoneNoneloggerXML (custom)None
0055NoneNoneNoneloggertextNone
0056NoneNoneNoneloggertext (custom)None
0057NoneNoneNoneWSO2EventWSO2Eventwso2-event
0058NoneNoneNoneWSO2EventWSO2Event (custom)wso2-event
0059NoneNoneNoneJMS (ActiveMQ)map/textjms
0060NoneNoneNoneJMS (Qpid)map (custom)/JSON (custom)jms
0061NoneNoneNoneJMS (WSO2 MB)map/XMLjms
0062NoneNoneNoneHTTPJSON/text (custom)/XMLgeneric-log-service
0063NoneNoneNoneSOAPXMLaxis2-log-service
0064NoneNoneNoneemailtext 
0065NoneNoneNoneSMSJSONSMSC Simulator
0066NoneNoneNoneMQTTJSONmqtt
0067NoneNoneNoneCassandramap 
0068NoneNoneNoneKafkaXML 
0069NoneNoneNoneWebsocketJSONwebsocket
0070NoneNoneNoneWebSocket localJSON 
0071NoneNoneNoneUIWSO2Event 
0072login-infoWSO2EventWSO2EventRDBMSmap 
  • No labels