Apama is a market-leading platform for performing streaming analytics and automating intelligent responses to fast-moving big data. Combining event processing, messaging, in-memory data management and visualization, Apama is a complete solution that can turn relentless data streams — like those produced by the Internet of Things (IoT) — into meaningful real-time metrics. Solace’s ability to efficiently route massive volumes of real-time information unlocks the full potential of Apama.

Apama Correlator’s built-in JMS adapter makes it easy to integrate Apama with JMS brokers like Solace’s. This integration guide includes a sample project that shows how to write up EPL modules and configure the JMS adapter to receive Solace messages, with message-to-event mapping the core of the project. Apama Workbench offers an GUI for mapping messages to events and vice versa, enabling Apama Correlator to efficiently and natively process external messages.

I wrote this integration guide for developers already familiar with Apama and JMS. It illustrates how to generate Solace messages and feed them into Apama via JMS adapter. It also includes information about the fun part of any project: debugging! By toggling configuration parameters, we can capture runtime debug logs from the Solace API library and Apama Correlator. Finally, Apama Dashboard is feature rich with an integrated tool palette from RTView, so depending on the use cases Apama Dashboard can offer in-depth view of the received business messages in real time.

Check out the integration guide now!

Wayne Sang

Wayne has worked as a developer and architect in financial services. In his career, he has delivered many global solutions, i.e. global payments, global audits, global account masters, global electronic trade executions, global market data services, global market risks, and etc. He is a subject matter expert in price aggregation, risk firewall, trade analytics, smart order routing, HFT algos and etc. His expertise is in CEP, EDA, SOA, MOM, RDMS, HA, cloud computing, big data, and etc.