Camel CEP

Complex Event Processing or Event Stream Processing are approaches of processing streams of events, usually from multiple sources.

Another approach to CEP with Camel is to use Camel RX which provides a typesafe DSL in Java, Scala, Groovy, clojure for processing events in a natural collection-like way (while being high performance and asynchronous under the covers). Camel RX uses the RxJava API which is a JVM port of the Reactive Extensions

CEP with Camel RX

Camel RX provides various ways to get an Observable<T> which provides the typesafe DSL for processing events on a single stream.

Once you have an Observable<T> you can then:

filter events * transform events
combine event streams
other utility methods