Package io.micronaut.rabbitmq.reactive

package io.micronaut.rabbitmq.reactive

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

Since:

1.1.0

Author:

James Kleeh

Class	Description
BrokerResponse	An enumeration to represent the three possible states of response from a broker.
RabbitPublishState	Stores the state of a RabbitMQ message to be published.
ReactivePublisher	A generic contract for publishing RabbitMQ messages reactively.
ReactorReactivePublisher	A reactive publisher implementation that uses a single channel per publish operation and returns a Reactor Mono.