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.
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 .
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 |
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 |
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 |