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.
Please see the getting started section in the reference documentation.
You need to have Java 8 installed.
With Maven:
<dependency>
<groupId>io.projectreactor.rabbitmq</groupId>
<artifactId>reactor-rabbitmq</artifactId>
<version>1.0.0.M1</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 'http://repo.spring.io/milestone' }
mavenCentral()
}
dependencies {
compile "io.projectreactor.rabbitmq:reactor-rabbitmq:1.0.0.M1"
}
./gradlew jar
./gradlew test
You need a local running RabbitMQ instance.
./gradlew eclipse
./gradlew idea
Reactor RabbitMQ is Apache 2.0 licensed.
Sponsored by Pivotal