Complex Event Processor

WSO2 Complex Event Processor

Routine business operations – a flight landed, a credit card processed, a package shipped – generate a constant stream of events. In a fast changing and competitive business climate, enterprises that monitor complex sequences of real-time events can quickly respond to their environment by anticipating problems and flagging opportunities. This will have greater business advantage over their competitors.

WSO2 Complex Event Processor identifies the most meaningful events within the event cloud, analyzes their impacts, and acts on them in real time. Built to be extremely high performing and massively scalable, it offers significant time saving and affordable acquisition.


Extremely High Performant Processing Engine

  • Processes more than 2.5M events/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 data, metadata and correlation 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.

Debugging Support

  • Event tracing, flow visualization and event simulation capabilities..

Massively Scalable

  • Supports 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 multiple CEPs configured with a Hazelcast distributed cache as a shared working memory.

Support for Long Duration Queries.

  • Queries can span lifetimes much greater than server uptime.
  • Supports 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
  • Supports recording and post processing of events with Map-Reduce via Apache Hadoop.

Built-in Support for WSO2 Products

  • Pre-built event sources from key 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 & 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