com.atlassian.confluence.content.render.xhtml.migration.exceptions.UnknownMacroMigrationException: The macro 'next_previous_links' is unknown.
WSO2 CEP Samples
- Former user (Deleted)
Owned by Former user (Deleted)
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.
- Each sample starts WSO2 CEP with a different configuration.
- After WSO2 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.
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. | Description | Producer (publish topic) | Event receiver type | Receiver message format | Event publisher type | Publisher message format | Consumer (subscription topic) |
|---|---|---|---|---|---|---|---|
| 0001 | Receiving JSON events via HTTP transport. | http | HTTP | JSON | logger | text | None |
| 0002 | Receiving custom JSON events via HTTP transport. | http | HTTP | JSON (custom) | logger | text | None |
| 0003 | Receiving XML events via HTTP transport. | http | HTTP | XML | logger | text | None |
| 0004 | Receiving custom XML events via HTTP transport. | http | HTTP | XML (custom) | logger | text | None |
| 0005 | Receiving text events via HTTP transport. | http | HTTP | text | logger | text | None |
| 0006 | Receiving custom text events via HTTP transport. | http | HTTP | text (custom) | logger | text | None |
| 0007 | Receiving WSO2 events via WSO2 Event Receiver. | wso2event | WSO2Event | WSO2Event | logger | text | None |
| 0008 | Receiving custom WSO2 events via WSO2 Event Receiver. | wso2event | WSO2Event | WSO2Event (custom) | logger | text | None |
| 0009 | Receiving map events via JMS transport - ActiveMQ. | jms | JMS (Active MQ) | map | logger | text | None |
| 0010 | Receiving custom map events via JMS transport - ActiveMQ. | jms | JMS (Active MQ) | map (custom) | logger | text | None |
| 0011 | Receiving JSON, text, XML events via JMS transport - ActiveMQ. | jms | JMS (Active MQ) | JSON/text/XML | logger | text | None |
| 0012 | Receiving map, XM events via JMS transport - Qpid | jms | JMS (Qpid) | map/XML | logger | text | None |
| 0013 | Receiving map, text events via JMS transport - WSO2 Message Broker. | jms | JMS (WSO2 MB) | map/text | logger | text | None |
| 0014 | Receiving XML events via SOAP transport. | soap | SOAP | XML | logger | text | None |
| 0015 | Receiving text events via Email transport. | None | text | logger | text | None | |
| 0016 | Receiving JSON events via MQTT transport. | mqtt | MQTT | JSON | logger | text | None |
| 0017 | Receiving custom text events via file tail transport. | file | file-tail | text (custom) | logger | text | None |
| 0018 | Receiving JSON events via Kafka transport. | kafka | kafka | JSON | logger | text | None |
| 0019 | Receiving JSON events via WebSocket transport. | websocket | websocket | JSON | logger | text | None |
| 0020 | Simple JSON pass-through with WebSocket local input event adaptor. | None | WebSocket local | JSON | logger | text | None |
| 0021 | Receiving map events via JMS transport - ActiveMQ (For Queue) | jms | JMS (ActiveMQ) | map | logger | text | None |
| 0022 | Receiving custom RegEx events via text events via file tail transport. | file | file-tail | text (custom) | logger | text | None |
Samples on processing events
| Sample no. | Description | Producer (publish topic) | Event receiver type | Receiver message format | Event publisher type | Publisher message format | Consumer (subscription topic) |
|---|---|---|---|---|---|---|---|
| 0101 | Pass-through/projection query in an execution plan. | wso2-event | WSO2Event | WSO2Event | logger | text | None |
| 0102 | Projections, transformations and enrichment for events. | None | (Event Simulator) | None | logger | text | None |
| 0103 | Using filters for generating alerts. | None | (Event Simulator) | None | logger | text | None |
| 0104 | Calculations over time using windows. | None | (Event Simulator) | None | logger | text | None |
| 0105 | Performing joins with windows. | None | (Event Simulator) | None | logger | text | None |
| 0106 | Using in-memory event tables. | None | (Event Simulator) | None | logger | text | None |
| 0107 | Using RDBMS event tables. | None | (Event Simulator) | None | logger | text | None |
| 0108 | Using patterns to detect ATM transaction frauds. | None | (Event Simulator) | None | logger | text | None |
| 0109 | Detecting trends with sequences. | None | (Event Simulator) | None | logger | text | None |
| 0110 | Sequences with partitioning to detect trends. | None | (Event Simulator) | None | logger | text | None |
| 0111 | Detecting non-occurrences with patterns. | http | HTTP | text | logger | text | None |
| 0112 | Analyzing Twitter feeds using partitions. | wso2-event | WSO2Event | WSO2Event | logger | JSON | None |
| 0113 | Limiting the output rate of an event stream. | http | HTTP | XML | logger | text | None |
| 0114 | Using external time windows. | wso2-event | WSO2Event | WSO2Event | logger | text | None |
| 0115 | Quartz scheduler based alerts. | http | HTTP | XML | logger | JSON | None |
| 0116 | Performing linear regression. | None | (Event Simulator) | None | logger | text | None |
| 0117 | Filtering and outputting to multiple streams. | file | file-tail | text | logger | text | None |
| 0118 | Using Hazlecast event tables. | None | (Event Simulator) | None | logger | text | None |
| 0119 | Trigger events at defined time intervals. | None | (Event Simulator) | None | logger | text | None |
| 0301 | Network intruder detection with PMML extension predictions. | None | (Event Simulator) | None | logger | text | None |
| 0501 | Processing a simple filter query with Apache Storm Deployment. | wso2-event | WSO2Event | WSO2Event | WSO2Event | WSO2Event | wso2-event |
| 0502 | Processing a window state over server restart. | http | HTTP | XML | logger | text | None |
| 0503 | Processing a window query in high availability mode. | http | HTTP | XML | logger | text | None |
| 0504 | Processing a distributed Siddhi query with partitioning by integrating with Apache Storm. | wso2-event | WSO2Event | WSO2Event | logger | text | None |
| 1001 | WSO2 CEP Geo Dashboard. | http | HTTP | JSON | websocket-local | JSON | None |
Samples on publishing events
| Sample no. | Description | Producer (publish topic) | Event receiver type | Receiver message format | Event publisher type | Publisher message format | Consumer (subscription topic) |
|---|---|---|---|---|---|---|---|
| 0051 | Publishing JSON events via logger transport. | None | None | None | logger | JSON | None |
| 0052 | Publishing custom JSON events via logger transport. | None | None | None | logger | JSON (custom) | None |
| 0053 | Publishing XML events via logger transport. | None | None | None | logger | XML | None |
| 0054 | Publishing custom XML events via logger transport. | None | None | None | logger | XML (custom) | None |
| 0055 | Publishing text events via logger transport. | None | None | None | logger | text | None |
| 0056 | Publishing custom text events via logger transport. | None | None | None | logger | text (custom) | None |
| 0057 | Publishing WSO2 events via WSO2Event transport. | None | None | None | WSO2Event | WSO2Event | wso2-event |
| 0058 | Publishing custom WSO2 events via WSO2Event transport. | None | None | None | WSO2Event | WSO2Event (custom) | wso2-event |
| 0059 | Publishing map and text events via JMS transport - ActiveMQ. | None | None | None | JMS (ActiveMQ) | map/text | jms |
| 0060 | Publishing custom map and JSON events via JMS transport - Qpid. | None | None | None | JMS (Qpid) | map (custom)/JSON (custom) | jms |
| 0061 | Publishing map and XML events via JMS transport - WSO2 MB. | None | None | None | JMS (WSO2 MB) | map/XML | jms |
| 0062 | Publishing XML, JSON and custom text events via HTTP transport. | None | None | None | HTTP | JSON/text (custom)/XML | generic-log-service |
| 0063 | Publishing XML events via SOAP transport. | None | None | None | SOAP | XML | axis2-log-service |
| 0064 | Publishing text events via Email transport. | None | None | None | text | ||
| 0065 | Publishing JSON events via SMS transport. | None | None | None | SMS | JSON | SMSC Simulator |
| 0066 | Publishing JSON events via MQTT transport. | None | None | None | MQTT | JSON | mqtt |
| 0067 | Publishing map events via Cassandra transport. | None | None | None | Cassandra | map | |
| 0068 | Publishing XML events via Kafka transport. | None | None | None | Kafka | XML | |
| 0069 | Publishing JSON events via WebSocket transport. | None | None | None | Websocket | JSON | websocket |
| 0070 | Publishing JSON events via WebSocket local output event adapter. | None | None | None | WebSocket local | JSON | |
| 0071 | Publishing WSO2Event events via UI transport. | None | None | None | UI | WSO2Event | |
| 0072 | Publishing map events via RDBMS transport. | login-info | WSO2Event | WSO2Event | RDBMS | map |
com.atlassian.confluence.content.render.xhtml.migration.exceptions.UnknownMacroMigrationException: The macro 'next_previous_links2' is unknown.