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.

For latest milestone: Getting Started - Reference Documentation

For snapshots: Getting Started - Reference Documentation

Documentation

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.2.0.RELEASE</version>
</dependency>

With Gradle:

dependencies {
  compile "io.projectreactor.rabbitmq:reactor-rabbitmq:1.2.0.RELEASE"
}

Milestones and release candidates

With Maven:

<dependency>
    <groupId>io.projectreactor.rabbitmq</groupId>
    <artifactId>reactor-rabbitmq</artifactId>
    <version>1.2.0.RC2</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.2.0.RC2"
}

Snapshots

With Maven:

<dependency>
    <groupId>io.projectreactor.rabbitmq</groupId>
    <artifactId>reactor-rabbitmq</artifactId>
    <version>1.3.0.BUILD-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.3.0.BUILD-SNAPSHOT"
}

Build intructions

Building Reactor RabbitMQ jars

./gradlew jar

Running unit tests

./gradlew test

You need a local running RabbitMQ instance.

Building IDE project

./gradlew eclipse
./gradlew idea

Community / Support

• For Reactor and Reactor RabbitMQ questions:
• For RabbitMQ questions: RabbitMQ Users
• For reporting bugs and feature requests: GitHub Issues

License

Reactor RabbitMQ is Apache 2.0 licensed.

Sponsored by Pivotal