Reactor RabbitMQ
Reactor RabbitMQ is a reactive API for RabbitMQ based on Reactor and RabbitMQ Java Client. Reactor RabbitMQ API enables messages to be published to RabbitMQ and consumed from RabbitMQ using functional APIs with non-blocking back-pressure and very low overheads. This enables applications using Reactor to use RabbitMQ as a message bus or streaming platform and integrate with other systems to provide an end-to-end reactive pipeline.
Getting started
For the latest stable release, please see the getting started section in the reference documentation. You can view the Javadoc as well.
For latest milestone: Getting Started - Reference Documentation - Javadoc
For snapshots: Getting Started - Reference Documentation - Javadoc
Building applications using Reactor RabbitMQ API
You need to have Java 8 installed.
With Maven:
<dependency>
<groupId>io.projectreactor.rabbitmq</groupId>
<artifactId>reactor-rabbitmq</artifactId>
<version>1.5.6</version>
</dependency>
With Gradle:
dependencies {
compile "io.projectreactor.rabbitmq:reactor-rabbitmq:1.5.6"
}
Milestones and release candidates
With Maven:
<dependency>
<groupId>io.projectreactor.rabbitmq</groupId>
<artifactId>reactor-rabbitmq</artifactId>
<version>1.5.6</version>
</dependency>
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
With Gradle:
repositories {
maven { url 'https://repo.spring.io/milestone' }
mavenCentral()
}
dependencies {
compile "io.projectreactor.rabbitmq:reactor-rabbitmq:1.5.6"
}
Snapshots
With Maven:
<dependency>
<groupId>io.projectreactor.rabbitmq</groupId>
<artifactId>reactor-rabbitmq</artifactId>
<version>1.5.7-SNAPSHOT</version>
</dependency>
<repositories>
<repository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/libs-snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>
With Gradle:
repositories {
maven { url 'https://repo.spring.io/libs-snapshot' }
mavenCentral()
}
dependencies {
compile "io.projectreactor.rabbitmq:reactor-rabbitmq:1.5.7-SNAPSHOT"
}
Build instructions
Building Reactor RabbitMQ jars
./gradlew jar
Running tests
The test suite needs to execute rabbitmqctl
to test connection recovery. You
can specify the path to rabbitmqctl
like the following:
./gradlew check -Drabbitmqctl.bin=/path/to/rabbitmqctl
You need a local running RabbitMQ instance.
Running tests with Docker
Start a RabbitMQ container:
docker run -it --rm --name rabbitmq -p 5672:5672 rabbitmq:3.9
Run the test suite:
./gradlew check -i -s
Building IDE project
./gradlew eclipse
./gradlew idea
Versioning
Reactor RabbitMQ used semantic versioning from version 1.0 to version 1.4, but switched to another scheme for consistency with Reactor Core and the other Reactor libraries.
Starting from 1.4, Reactor RabbitMQ uses a GENERATION.MAJOR.MINOR
scheme, whereby an increment in:
GENERATION
marks a change of library generation. Expect improvements, new features, bug fixes, and incompatible API changes.MAJOR
marks a significant release. Expect new features, bug fixes, and small incompatible API changes.MINOR
marks a maintenance release. Expect new features and bug fixes, but no incompatible API changes.
Community / Support
- For Reactor and Reactor RabbitMQ questions:
- For RabbitMQ questions: RabbitMQ Users
- For reporting bugs and feature requests: GitHub Issues
See the RabbitMQ Java libraries support page for the support timeline of this library.
License
Reactor RabbitMQ is Apache 2.0 licensed.
Sponsored by VMware