...
- Joins
pizza_deliveries
table with theoverdueDeliveries
stream (the aliasoverdueStream
is used for convenience here) - Uses a join operation to compare each event in the event table (
pizza_deliveries
) with each incoming event fromoverdueDeliveries
stream
Note that,- Events received through the
overdueDeliveries
arrive 30 seconds after the actual order happens - A result of this join operation indicates (since we match the order ids) that the order is already delivered within 30 seconds
- Events received through the
- Inserts the successful delivery information to the
deliveredOrders
stream, which can be used to monitor the status of orders
Prerequisites
See Prerequisites in CEP Samples Setup page.
...
Start the WSO2 CEP server with the sample configuration numbered 0108. For instructions, seeĀ Starting sample CEP configurations. This sample configuration does the following:
...