22. Integrating Storm and JMS

We’ve gone through the basic concepts of Storm with a simple application. We’ve also written a basic JMS server and client in Clojure. Now we’re going to make Storm more useful by integrating JMS as a Spout.

The big idea in this chapter is pricing information. We’re going to have a JMS feed of stock prices flowing through the system. Using the EPS information also in the message, Storm will first determine (using a simplistic algorithm) whether the price represents good value or not and then issue a recommendation.

In this recipe we’ll create a Storm spout that reads from the JMS queue. Then we’ll integrate this with a Storm topology that routes messages based on their content. Finally, we’ll see the resulting output ...

Get Clojure Recipes now with O’Reilly online learning.

O’Reilly members experience live online training, plus books, videos, and digital content from 200+ publishers.