Features

Extremely High Performant Processing Engine

• Process more than 2.5M events per sec on single-server commodity hardware
• Powered by WSO2 Siddhi

Powerful and Extensible Query Language for Temporal Event Stream Processing

• Filter events by conditions
• Join event streams and create new streams
• Execute temporal queries using various windows
• Detect and respond to various event patterns and sequences
• Process historical data in RDBMS in real-time

Support for Rich Event Model

• Events modeled as tuples of metadata, correlation data and payload data.
• Support for typed properties including integral types, floating types, string and Boolean

Extremely High Performant Event Capturing and Delivery Framework Over Apache Thrift or HTTP

• Java data publisher agent to plug into any Java based system
• Data publisher agent support in other languages (C/C++/C#) via Thrift language bindings
• Horizontally scalable to support very large event volumes

Easily Integrates with any Enterprise System for Event Capture

• RESTful HTTP protocol with JSON, XML and Text
• JMS Map, JSON, XML and Text messages
• SOAP over any transport protocol
• Kafka, File and Email protocols with JSON, XML and Text messages

Effective Event Publishing to Enterprise Systems and Custom Notifications

• XML, JSON, Map, Text events via JMS protocol
• E-mail, SMS notifications
• Service calls to notify RESTful services and Web services
• MySQL and Cassandra writers

• Event tracing, flow visualization and event simulation capabilities

Massively Scalable

• Support large numbers of queries via partitioning into different servers
• Massive working memory support via distributed caching with Hazelcast
• Distributed chaining of complex queries

Highly Available Deployment

• Run CEP with redundant nodes and with coordination and state sharing

Support for Long Duration Queries

• Queries can have lifetimes that are much greater than server uptime
• Support periodic snapshots that can store all state information and windows to a scalable persistence store (Apache Cassandra).
• Pluggable persistent stores

Tightly Integrates with WSO2 Business Activity Monitor

• Leverage Lambda architecture to integrate post-processed data with real-time data processing
• Support recording and post processing of events with Map-Reduce via Apache Hadoop

Built-in Support for WSO2 Products

• Pre-built event sources from other WSO2 products

Lightweight, Developer Friendly and Easy to Deploy

• Server customization via provisioning of features
• Deployment options from on-premise to private or public clouds, without configuration changes
• Integrated with WSO2 Developer Studio, the Eclipse-based IDE for all WSO2 products

Manage and Monitor

• Comprehensive management and monitoring Web console with enterprise-level security
• Built-in collection and monitoring of standard access and performance statistics
• Flexible logging support with integration to enterprise logging systems
• In build support for rich representation of data through a dashboard