reactor-rabbitmq

library1.5.6javamavenunverified

Reactor RabbitMQ: A reactive API for RabbitMQ based on Project Reactor.

<dependency>
  <groupId>io.projectreactor.rabbitmq</groupId>
  <artifactId>reactor-rabbitmq</artifactId>
  <version>1.5.6</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · REACTOR-RABBITMQ

reactor-rabbitmq

messagingjavav1.5.6

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

Receiver

✓ reactor.rabbitmq.Receiver

Consumes messages from a RabbitMQ queue reactively.

import reactor.rabbitmq.Receiver; import reactor.rabbitmq.RabbitFlux; import reactor.core.publisher.Flux; public class Quickstart { public static void main(String[] args) throws Exception { Receiver receiver = RabbitFlux.createReceiver(); Flux<String> messages = receiver.consumeAutoAck("queue") .map(delivery -> new String(delivery.getBody())); messages.subscribe(System.out::println); } }

Debug

Known issues

breakingReactor RabbitMQ 1.x uses Reactor Core 3.x; ensure compatible versions.

fix

Use Reactor RabbitMQ 1.5.x with Reactor Core 3.4.x or later.

affects: >=1.0.0 <2.0.0

Upgrade

Version history

1.5.6latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

24 hits · last 30 days

node

Amazon

OpenAI (training)

Resources

githubhttps://github.com/reactor/reactor-rabbitmq ↗

homepagehttps://github.com/reactor/reactor-rabbitmq ↗

docshttps://appdoc.app/artifact/io.projectreactor.rabbitmq/reactor-rabbitmq/ ↗