Complex Event Processor

WSO2 Complex Event Processor

Data to insight in a flash, routine business operations – a flight landed, a credit card processed, a package shipped – generate a constant high volume, stream of events. In a fast changing and competitive business climate, identifying meaningful patterns from large set of incoming data events from multiple sources in real time helps a connected business gain business agility by anticipating risks or flagging opportunities thereby responding to the urgent business situations in real time.

WSO2 CEP is part of WSO2 Big Data Analytics Platform where it provides the Realtime Analytics pipeline. WSO2 CEP integrates closely with WSO2 Business Activity Monitor.



WSO2 CEP captures events from various data sources through different protocols and data formats as event streams. These event streams are then analyzed using the high performance Siddhi CEP Engine, with easy to use SQL like query language. This facilitates temporal correlations between event streams with historic data, that in turn enables detection of complex event patterns. The output is then published as a stream of events to various backend systems as alerts via different protocols and data formats, with visualization support. The WSO2 CEP provides enterprise level management, statistics, debugging and tracing support for the whole event flow, enabling highly scalable and high availability deployments.

Managed Cloud

Need to get WSO2 Complex Event Processor as a service? We will be happy to run them for you in our Managed Cloud with guaranteed SLA.

  • Run in the region of your choice on dedicated virtual machines not shared with any other customers.
  • WSO2 engineers set up the environment including the virtual machines, WSO2 products, and networking.
  • Option to have network connectivity with your on-premise datacenter.
  • Deployment can be customized for your specific needs.
  • Can be combined with professional services including consultancy, development, and WSO2 QuickStart.
  • Includes full devops service including 24*7 monitoring, regular backups, and product updates.
  • Priced at a fixed monthly fee.

For more infomation on the guaranteed service level see


  • Extremely high performance engine.
  • 100K+ events/sec over network on commodity hardware (e.g. 4 core 4GB CPU).
  • Capable of processing 6M events/sec when event generated from same JVM.
One of the four finalist in DEBS Grand Challenge 2014.
0.8 Million event/sec on four nodes for a complex query. more details


Process data in flow and Analyze in real time.

  • Powerful, extensible comprehensive language for stream processing powered by WSO2 Siddhi.
  • SQL like query language providing intuitive and complex event processing support.
  • Supports filter by conditions, create and join event streams, executes temporal queries using various windows, identifies sequence of events occurrences.

Connect and Integrate to any event source.

  • Support for many transport adapters including for IoT.
  • Data publisher agents to plug into enterprise systems.
  • Tight Integration with WSO2 Business Activity Monitor for historic and batch processing.

Extend platform and distribute event processing for Scalability and High Availability.

  • Extensible use case driven toolbox support including fraud detection, time series, geo fencing, Natural Language Processing plugin.
  • Scale CEP using query chaining and partitioning into multiple CEP nodes with distributed cache.
  • Supports long running queries via persistence support with Cassandra

Visualize, Monitor and Act on business events in real time

  • Event tracing, event flow visualization and event simulation capabilities.
  • Built-in collection and monitoring of standard access and performance statistic.
  • Effective real time dashboard with support for gadget generation.