Package io.micronaut.configuration.rabbitmq.reactive

Contains classes specific to converting the RabbitMQ java client API to a reactive API.

See: Description

Interface Summary

Interface	Description
ReactivePublisher	A generic contract for publishing RabbitMQ messages reactively.

Class Summary

Class	Description
RabbitPublishState	Stores the state of a RabbitMQ message to be published.
RxJavaReactivePublisher	A reactive publisher implementation that uses a single channel per publish operation and returns an RxJava2 Completable.

Enum Summary

Enum	Description
BrokerResponse	An enumeration to represent the three possible states of response from a broker.

Package io.micronaut.configuration.rabbitmq.reactive Description

Contains classes specific to converting the RabbitMQ java client API to a reactive API.

Since:

1.1.0

Author:

James Kleeh