All docs
This doc
WSO2 DAS 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 DAS with a different configuration.
- After WSO2 DAS starts, the sample producers send different types of events to the DAS over different transports.
- The DAS 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 real time samples, demonstrating use cases of WSO2 DAS.
The following table summarizes the producer/consumer clients and the mapping types of each WSO2 DAS sample. For instructions to set up the samples, see Setting Up Real Time 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 DAS 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 |
Overview
Content Tools
Activity
- Get Support
Download PDF
Download a PDF file of the documentation