io.micronaut.configuration.rabbitmq.reactive

Class RabbitPublishState

java.lang.Object

io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState

@Immutable
public class RabbitPublishState
extends Object

Stores the state of a RabbitMQ message to be published.

Since:

1.1.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor and Description
RabbitPublishState(String exchange, String routingKey, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body) Default constructor.

Method Summary

Modifier and Type	Method and Description
byte[]	getBody()
String	getExchange()
com.rabbitmq.client.AMQP.BasicProperties	getProperties()
String	getRoutingKey()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RabbitPublishState

public RabbitPublishState(String exchange,
                          String routingKey,
                          com.rabbitmq.client.AMQP.BasicProperties properties,
                          @Nullable
                          byte[] body)

Default constructor.

Parameters:

exchange - The exchange

routingKey - The routing key

properties - The properties

body - The body

Method Detail

getExchange

public String getExchange()

Returns:

The exchange to publish the message to

getRoutingKey

public String getRoutingKey()

Returns:

The routing key

getProperties

public com.rabbitmq.client.AMQP.BasicProperties getProperties()

Returns:

The properties

getBody

@Nullable
public byte[] getBody()

Returns:

The message body