)
This project provides a Redis Stream-based SmallRye Reactive Messaging connector that enables the use of the MicroProfile Reactive Messaging API over Redis Stream. The implementation allows seamless integration of asynchronous data streams into WildFly and Quarkus-based applications.
For more details on MicroProfile Reactive Messaging, check:
For information on SmallRye Reactive Messaging, visit:
This repository consists of the following main components:
A Reactive Messaging connector compatible with WildFly that handles Redis Stream-based data flows. Similar to existing connectors (Kafka, AMQP, etc.), this can be configured without needing to manage the underlying implementation manually.
For easy integration with Quarkus, the connector is also available as a Quarkus extension. This extension helps with configuration and optimizes the runtime environment. The extension consists of two main parts:
-
Runtime: Contains components required during application execution.
-
Deployment: Handles configuration aspects needed at build time.
The RedisStream connector can be configured using MicroProfile Config properties. The following example demonstrates a simple producer-consumer setup:
mp.messaging.incoming.my-stream.connector=redis-stream
mp.messaging.incoming.my-stream.channel=my-channel
mp.messaging.outgoing.my-stream.connector=redis-stream
mp.messaging.outgoing.my-stream.channel=my-channelYou can test the solution by running the sample project.