Package io.micronaut.rabbitmq.reactive

Class RabbitPublishState

java.lang.Object

io.micronaut.rabbitmq.reactive.RabbitPublishState

public class RabbitPublishState
extends 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	Description
RabbitPublishState(String exchange, String routingKey, boolean mandatory, com.rabbitmq.client.AMQP.BasicProperties properties, @io.micronaut.core.annotation.Nullable byte[] body)	Default constructor.
RabbitPublishState(String exchange, String routingKey, com.rabbitmq.client.AMQP.BasicProperties properties, @io.micronaut.core.annotation.Nullable byte[] body)	Deprecated, for removal: This API element is subject to removal in a future version. Use RabbitPublishState(String, String, boolean, AMQP.BasicProperties, byte[])

Method Summary

Modifier and Type	Method	Description
@io.micronaut.core.annotation.Nullable byte[]	getBody()
String	getExchange()
boolean	getMandatory()
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 Details

RabbitPublishState

public RabbitPublishState(String exchange,
 String routingKey,
 boolean mandatory,
 com.rabbitmq.client.AMQP.BasicProperties properties,
 @Nullable
 @io.micronaut.core.annotation.Nullable byte[] body)

Default constructor.

Parameters:

exchange - The exchange

routingKey - The routing key

mandatory - The "mandatory" flag

properties - The properties

body - The body

Since:

4.1.0

RabbitPublishState

@Deprecated(since="4.1.0",
            forRemoval=true)
public RabbitPublishState(String exchange,
 String routingKey,
 com.rabbitmq.client.AMQP.BasicProperties properties,
 @Nullable
 @io.micronaut.core.annotation.Nullable byte[] body)

Deprecated, for removal: This API element is subject to removal in a future version.

Use RabbitPublishState(String, String, boolean, AMQP.BasicProperties, byte[])

Deprecated constructor.

Parameters:

exchange - The exchange

routingKey - The routing key

properties - The properties

body - The body

Method Details

getExchange

public String getExchange()

Returns:

The exchange to publish the message to

getRoutingKey

public String getRoutingKey()

Returns:

The routing key

getMandatory

public boolean getMandatory()

Returns:

The "mandatory" flag

Since:

4.1.0

getProperties

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

Returns:

The properties

getBody

@Nullable
public @io.micronaut.core.annotation.Nullable byte[] getBody()

Returns:

The message body