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:
Code Block |
---|
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
- See Prerequisites in CEP Samples Setup page.
- Copy the ActiveMQ JMS related JARs referred in JMS Transport to
<CEP_HOME>/repository/components/lib
directory
...
- .
...
...
- Copy the following JARs from ActiveMQ distribution directory to
<CEP_HOME>/samples/lib
directory
...
- .
<ActiveMQ_HOME>/activemq-all-5.7.0.jar
<ActiveMQ_HOME>/lib/ geronimo-jms_1.1_spec-1.1.1.jar
...
Also copy apache axiom.jar
...
to
...
<CEP_HOME>/samples/lib
directory
...
to send
...
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
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.
as itInfo Do not close this terminal
in order to receive events and view them.. It is required to keep the server running
From another terminal switchInfo ant queueConsumer -Dqueue=DelayedFlightStats (Since we are sending events from CEP to a topic called DelayedFlightStats
and receiving events.
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.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
Once the step 2 is done successfully, you will be able to
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. For example,