Clojure Recipes

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 ...