Page Comparison

Table of Contents

Introduction

This sample demonstrates how to set up an execution plan with a simple filter. It checks for delayed flight arrival and add the specific flights and adds related flight event events to the stream called delayedFlightStream. named delayedFlightStream. This sample uses jms queues for processing.

The query used in this sample is as follows:

from flightStatsStream[status != 'On-Time']
select flightName, flightId, flightType, arrivalTime, trackNo
insert into delayedFlightStream  

This sample has used jms queues for the processing.

Prerequisites

For a list of prerequisites, please refer to the prerequisites section in Setting up CEP Samples.

...

Prerequisites

1. See Prerequisites in CEP Samples Setup page.
2. If you use ActiveMQ, add the following JMS related JARs from ActiveMQ distribution directory to <CEP_HOME>/repository/

...

1. components/lib directory

...

1. . Also see JMS Transport for more information about required JARs.
   

   • <ActiveMQ_HOME>/activemq-all-5.7.0.jar

   • <ActiveMQ_HOME>/lib/ geronimo-jms_1.1_spec-1.1.1.jar

...

1. • Also copy apache axiom.jar

...

1. • to

...

1. • <CEP_HOME>/samples/lib directory

...

1. • to send

...

1. • XML event types

   Note
   Start the ActiveMQ server before the CEP server starts.

Building the

...

sample

Start the WSO2 CEP server with the sample

...

configuration numbered 0103. For instructions, see Starting sample CEP configurations. This sample configuration does the following:

• Creates <CEP_HOME>/repository/conf

...

• /stream-manager-config.xml file, which is used to create the stream definitions

...

• for the sample.

...

• Points the default Axis2 repo

...

• to

...

• <CEP_HOME>/sample/artifacts/0103 (by default, the Axis2 repo is <CEP_HOME>/repository/deployment/server).

...

Executing the

...

sample

1. Open another terminal and switch a new terminal, go to <CEP_HOME>/samples/consumers/jms and run the below command. This will build command below.

   Code Block
   ant queueConsumer -Dqueue=DelayedFlightStats (Since we are sending events from CEP to a topic called DelayedFlightStats)

   It builds the sample jms consumer and execute executes it.

   Info
   Do not close this terminal

   as it

   . It is required to keep the server running

   in order to receive events and view them.

   Info
   ant queueConsumer -Dqueue=DelayedFlightStats (Since we are sending events from CEP to a topic called DelayedFlightStats

   From another terminal switch

   and receiving events.

2. Open another terminal, go to <CEP_HOME>/samples/producers/flight-stats/ and run ant from there. This will build and run
   
   It builds and runs the jms producer, which will send some sends flight stats data to the CEP server.

3. From this terminal, you will be able to view see the details of the events sent.

   Info
   title Note
   To configure queue use -Dqueue=xxxx For example : ant -Dqueue=FlightStats

   Image Removed

   Once the step 2 is done successfully, you will be able to Image Added

4. Also, see the output events received from the CEP via the terminal opened in step 1. Below is the console output in the CEP server when events are received after processing. Image RemovedFor example,Image Added