com.atlassian.confluence.content.render.xhtml.migration.exceptions.UnknownMacroMigrationException: The macro 'next_previous_link3' is unknown.
WSO2 DAS Real Time Samples
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 |
com.atlassian.confluence.content.render.xhtml.migration.exceptions.UnknownMacroMigrationException: The macro 'next_previous_links2' is unknown.