io.micronaut.rabbitmq.reactive

Class RabbitPublishState

java.lang.Object

io.micronaut.rabbitmq.reactive.RabbitPublishState

public class RabbitPublishState
extends java.lang.Object

Stores the state of a RabbitMQ message to be published. This class should be treated as immutable.

Since:

1.1.0

Author:

James Kleeh

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
byte[]	getBody()
java.lang.String	getExchange()
com.rabbitmq.client.AMQP.BasicProperties	getProperties()
java.lang.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(java.lang.String exchange,
                          java.lang.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 java.lang.String getExchange()

Returns:

The exchange to publish the message to

getRoutingKey

public java.lang.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