io.micronaut.configuration.rabbitmq.reactive

Interface ReactivePublisher<T>

Type Parameters:

T - The reactive type

All Known Implementing Classes:

RxJavaReactivePublisher

public interface ReactivePublisher<T>

A generic contract for publishing RabbitMQ messages reactively.

Since:

1.1.0

Author:

James Kleeh

Method Summary

Modifier and Type	Method and Description
T	publish(String exchange, String routingKey, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body) Publish the message with the provided arguments and return a reactive type that completes successfully when the broker acknowledged the message.

Method Detail

publish

T publish(String exchange,
          String routingKey,
          com.rabbitmq.client.AMQP.BasicProperties properties,
          byte[] body)

Publish the message with the provided arguments and return a reactive type that completes successfully when the broker acknowledged the message.

Parameters:

exchange - The exchange

routingKey - The routing key

properties - The properties

body - The body

Returns:

The reactive type to subscribe to