Chapter 16 – Oracle Event Processor for Fast Data and Complex Events

The Oracle Event Processor (OEP) is a component integrated in SOA Suite that provides the capability to process fast data and produce business events from continuous streams of fine grained data events. OEP can consume fast data from various channels – including JMS, EDN, HTTP/REST, RMI – and supports creation of custom adapters for collection fast data from for example Twitter, Messaging systems such as Tibco Rendezvous, Sockets, APIs from financial data feeds etc. Similar adapters are used to publish the outcomes produced by OEP. The integration between OEP and SOA composites and Service Bus hinges on JMS and EDN.

OEP is not only for processing huge volumes of events. It will also be the tool of choice for detection of predefined patterns that span cross process instances and service calls. OEP can be made to remember business events for quite some time and rapidly correlate additional (or missing) events to produce a relevant insight or alert.

In this chapter, we will use OEP to process a simulated feed with car park events that report cars entering and leaving one of the car parks at Saibot Airport. These events are processed to produce messages on JMS whenever a car park is close to filling up. Using the event stream, OEP will detect towing candidates: cars that have been abandoned or that at least have stayed in the car park for longer than 48 hours. OEP will also produce car stay events – derived from the base car entry and car leaving events – that are then aggregated to produce average car stay duration reports.

Finally, OEP is used by the security department at Saibot Airport – to detect a string of suspicious credit card transactions in the airport’s shopping area, following a specific pattern identified in earlier theft cases. Such findings are reported as business events on EDN to be taken care of by one or more SOA composite applications.

Sections in this chapter:

These figures illustrate the components to be developed in this chapter.