Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Joins pizza_deliveries table with the overdueDeliveries stream (the alias overdueStream is used for convenience here)
  • Uses a join operation to compare each event in the event table (pizza_deliveries) with each incoming event from overdueDeliveries 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
  • 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:

...