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 ...
Become an O’Reilly member and get unlimited access to this title plus top books and audiobooks from O’Reilly and nearly 200 top publishers, thousands of courses curated by job role, 150+ live events each month,
and much more.
Read now
Unlock full access