On behalf of the RabbitMQ team I'm happy to announce that Reactor
RabbitMQ 1.3.0 Milestone 2 is available for community testing.
Reactor RabbitMQ [1] is a reactive API for RabbitMQ based on Reactor
[2] and RabbitMQ Java Client. Reactor RabbitMQ goal is to enable
messages to be published to and consumed from RabbitMQ using
functional APIs with non-blocking back-pressure and very low overhead.
This pre-release includes new features, bug fixes, and dependency
upgrades. It is compatible with 1.2.0.RELEASE.
Thanks to Kristof Van Sever, Pawel Mackowski, and Phil Clay for their
contribution on this pre-release.
Changes:
* Add support for handling returned (undeliverable) messages in Sender
* Allow passive exchange and queue declaration
* Add hook to configure Mono<Connection>
* Support client-generated consumer tags
* Make Sender and Receiver closing more robust
* Remove ConfirmListener from Channel
* Cache Connection and Channel only on success
* Using connectionSupplier results in multiple connections created
* Emit exception on server-initiated channel closing
* Do not close channel in RpcClient
* Bump Reactor to 3.3.0.M3
* Bump Java client to 5.7.3
* Make sure RPC client is thread-safe
See the changelog [3] for more details.
Dependency (Maven artifact)
Maven:
<dependency>
<groupId>io.projectreactor.rabbitmq</groupId>
<artifactId>reactor-rabbitmq</artifactId>
<version>1.3.0.M2</version>
</dependency>
Gradle:
compile "io.projectreactor.rabbitmq:reactor-rabbitmq:1.3.0.M2"
This milestone version is available on Spring Milestones repository.
You need to add this repository explicitly to your dependency manager
configuration file.
Maven:
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>
https://repo.spring.io/milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
Gradle:
repositories {
maven { url '
https://repo.spring.io/milestone' }
}
[1]
https://github.com/reactor/reactor-rabbitmq
[2]
https://projectreactor.io/
[3]
https://github.com/reactor/reactor-rabbitmq/releases/tag/v1.3.0.M2