Page History

...

One approach to CEP with Camel is to use the esper Esper endpoint then use Esper's SQL-like DSL for working with event streams.

...

Note that at the time of writing, some of the RX APIs have not yet been ported to RxJava so that some of the core CEP functions are not yet implemented. e.g. these functions will really complete RxJava's CEP coverage:

• window() provides time windows over events
• groupBy()
• join()

So until RxJava hits 0.7 milestone there is limited support for joining streams (other than zip); but that should hopefully be fixed soon. I'm sure the RxJava folks would welcome contributions on those issues