Reactive messaging with JMS connector
When it comes to integration with messaging systems, JMS API is one of the most popular solutions out there. So it’s no wonder Helidon 2.2.0 comes with direct support for connecting its reactive messaging to JMS.
Let’s try to connect Helidon to Apache ActiveMQ over JMS, it’s super easy to set up and we can focus on the connector itself.
First, start ActiveMQ in the docker:
docker run --name='activemq' -p 61616:61616 -p 8161:8161 rmohr/activemq
When we have JMS server to play with, it’s time for tweaking Helidon.
Oracle Advanced Queueing (AQ) is the message queueing service used by the Oracle database. By providing PLSQL and JMS APIs in Advanced Queueing, Helidon is now uniquely positioned to interact with database events and benefit from Oracle database’s durability and high availability.
We are pleased to announce that Helidon 2.2.0, a first class citizen in the Oracle ecosystem, now comes with a specialized connector for reactive messaging.
A simple script for setting up a local docker container within Oracle 18 XE is available in Helidon messaging examples. To build and run the script, simply execute buildAndRun.sh. Note that the first…
Oracle Cloud Infrastructure Streaming service is a great alternative to Apache Kafka in the OCI environment. It is a fully managed service so maintenance, security patching, replication, monitoring and metrics are literally one click away from your OCI console. Connecting to OCI Streaming with Helidon is as easy as connecting to Kafka, or actually it is quite the same because OCI Streaming understands Kafka clients.
Reactive birds flock together
With Reactive Messaging support coming with Helidon 2.0, Kafka connector is one of the first messaging connectors available for both flavors of Helidon MP and Helidon SE. Helidon MP follows the MicroProfile specification to the letter and leverages all of the great features of CDI. With Helidon SE you can enjoy simplistic API, explicit configuration, and the “ no-magic” approach users enjoy about SE.
Asynchronous messaging is a commonly used form of communication in the world of microservices and Reactive Messaging for MicroProfile specification is a logical response to the need for formalizing ways to connect things together.
What is the best way to communicate asynchronously? Via Reactive Streams of course! To formalize manipulation with reactive streams, another specification had to emerge and that is MicroProfile Reactive Streams Operators. Reactive messaging heavily depends on standardized operators to provide great portability between existing implementations.
The pre-release version of Helidon’s Reactive Messaging and Reactive Streams Operators are included in the Helidon 2.0.0-M2 release.
Note: Pre-release versions…
Java developer at Oracle