Over a million developers have joined DZone.
{{announcement.body}}
{{announcement.title}}

WSO2 CEP with ActiveMQ JMS Broker

DZone's Guide to

WSO2 CEP with ActiveMQ JMS Broker

· Integration Zone
Free Resource

Today’s data climate is fast-paced and it’s not slowing down. Here’s why your current integration solution is not enough. Brought to you in partnership with Liaison Technologies.

If you need simple a WSO2 CEP simple sample, try out this. This post explains how use WSO2 CEP and ActiveMQ JMS Broker to publish and subscribe events.

Prerequisite

install ActiveMQ JMS Broker.

Before Start CEP

1. Copy
activemq-all-xxx.jar

from the <ActiveMQ_HOME> directory to <CEP_HOME>/samples/lib directory.

2.Copy
activemq-core-xxx.jar
geronimo-j2ee-management_1.1_spec-1.0.1.jar

from <ActiveMQ_HOME>/lib to <CEP_HOME>/repository/components/lib directory.

3.Go to <CEP_HOME>/samples/cep-samples and enter "ant deploy-jms"

imageimage

image

This will copy the broker-manager-config.xml

4. Now start the WSO2 Complex Event Processor from wso2server.bat/sh

Starting JMS Subscriber

5. Start ActiveMQ JMS Broker
6. Enter "ant jmsSubscriber -Dtopic=PredictedStockQuotes" <CEP_HOME>/samples/cep-samples

image


Publishing Events
7. Go to <CEP_HOME>/samples/cep-samples and type "ant jmsAllStockQuotesPublisher"

image

8. You will be able observe the output events in the JMS subscriber console as shown bellow.

image

Is iPaaS solving the right problems? Not knowing the fundamental difference between iPaaS and iPaaS+ could cost you down the road. Brought to you in partnership with Liaison Technologies.

Topics:

Published at DZone with permission of Madhuka Udantha, DZone MVB. See the original article here.

Opinions expressed by DZone contributors are their own.

THE DZONE NEWSLETTER

Dev Resources & Solutions Straight to Your Inbox

Thanks for subscribing!

Awesome! Check your inbox to verify your email so you can start receiving the latest in tech news and resources.

X

{{ parent.title || parent.header.title}}

{{ parent.tldr }}

{{ parent.urlSource.name }}