Skip to content

Esper demo using Java Message Service(JMS) to provide input data. Sping frameword is used.

License

Notifications You must be signed in to change notification settings

liangyihuai/Esper4SpingJMS

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

4 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Esper4SpingJMS

This is simple demonstration on message processing using Esper, Sping and JMS(java message service).

Simple project that illustrates the use of the Esper Complex Event Processing Engine. Purposefully left Unit Tests out to reduce size of code.

When the demo runs it will just simulate sending random temperature events through the processing engine. It will print debug messages to the console when it detects a sequence of events matching any of the 3 criteria statements we have defined (Critical, Warning, Monitor).

To generate input data, JMS(ActivMQ) is used as a remote event provider.

requirements

You will need Maven installed and working.

It is suggested to using the IDE of Intelij IDEA to run the project quickly.

The component of Apache ActiveMQ is consisted of the project. So it is needed to download the Apache ActiveMQ, unzip it and double click the file of activemq.bat under apache-activemq-5.15.0\bin\win64 path.(Don't worry about the installation of Apache ActiveMQ, it is very simple actually.)

Before you run the demo, start the ActiveMQ service please.

setup

To run demo:

  • method 1:
  1. Open a terminal window

  2. Navigate to the root directory of the project (where the pom.xml is)

  3. 'mvn clean install' (this will compile and build the project)

  4. 'mvn exec:java' (this will start running the demo - sending random temperature events)

  • method 2:
  1. Use Git URL. copy https://github.com/liangyihuai/Esper4SpingJMS.git

  2. build a IDEA project by using above URL.

我写了一篇中文博客:https://blog.csdn.net/liangyihuai/article/details/79705357

About

Esper demo using Java Message Service(JMS) to provide input data. Sping frameword is used.

Topics

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages