Overview of Samples
- Former user (Deleted)
- Former user (Deleted)
- Former user (Deleted)
Required prerequisites for samples
Following applications are required for running the CEP samples in this documentation:
| Application | Purpose | Version | Download Links |
|---|---|---|---|
| Apache Active MQ | The JMS samples are explained to be tried out using Active MQ. The ActiveMQ client libraries must be installed in the product's classpath before you can enable the JMS transport. For more information, see JMS Transport section. | 5.2.0 or later | |
| Apache Ant | To compile and run the product samples. | 1.7.0 or later | http://ant.apache.org |
| Oracle Java SE Development Kit (JDK) | To launch the product and to run Apache Ant. | 1.6.24 or later / 1.7.* | http://java.sun.com/javase/downloads/index.jsp |
Understanding the samples
CEP samples explain different usecases of the product using sample clients (producers and consumers). The general flow of all samples is as follows:
- Each sample starts the CEP with a different configuration.
- After the CEP starts, the sample producers send different types of events to the CEP over different transports.
- The CEP receives these events and processes them.
- Finally it pushes different types of notification events based on the processed data to the sample consumers over different transports.
The following table summarizes the producer/consumer clients and the mapping types of each CEP sample. See Setting up CEP Samples for instructions to set up and run samples.
| Sample No | Producer [Publish Topic] | Consumer [Subscription Topic] | Input Adapter Type | Event Builder Type | Event Formatter Type | Output Adapter Type | Comments |
|---|---|---|---|---|---|---|---|
| 0001 | service-stats | wso2event | wso2event | wso2event | wso2event | wso2event | |
| 0002 | stock-quote [AllStockQuotes] | jms [BasicStockQuotes] | jms (activemq) | json | map | jms | |
| purchase-info | logService | jms (activemq) | map | xml | http | ||
| 0004 | email (Refer to ReadMe.txt) | jms | text | json | jms | ||
| 0005 | pizza-shop | email (Refer to ReadMe.txt ) | http | xml | text | ||
| 0006 | service-stats | wso2event | wso2event | wso2event | wso2event | wso2event | |
| 0101 | mediation-stats | wso2event | wso2event | wso2event | wso2event | wso2event | |
| 0102 | twitter-feed, stock-quote [AllStockQuotes] | log-service [PredictedStockQuotes] | jms, wso2event | json, wso2event | xml | http |
|
| 0103 | flight-stats | jms Queue consumer | jms (activemq) | xml | text | jms | Add necessary active-mq related client jars & axiom jar |
| 0104 | login-info | wso2event | wso2event | wso2event | wso2event | wso2event | |
| 0105 | atm-transaction-stats | log-service | soap | xml | xml | soap | |
| 0106 | build-failure-rest-api | wso2event (Through rest api) | wso2event | text | Follow the instruction in readme.txt to send events. | ||
| 0107 | mediation-stats | wso2event | wso2event | wso2event | wso2event | wso2event | Need to have 2 consumer test-servers in port 7611 & 7612 (To test Load-balancing) |
| 0108 | pizza-shop (pizzaPublisherClient) | wso2event | wso2event | wso2event | wso2event | wso2event | |
| 0109 | pizza-shop (pizzaPublisherClient) | wso2event | wso2event | wso2event | wso2event | wso2event | With Persistence based Event tables (with cache) |
| 0110 | sensor-stats | kafka | kafka | xml | json | kafka | |
| 0111 | soap try it | logService (axis2) | soap | xml | xml | soap | |
| 0112 | logFile | logger | file | text | text | logger |