reactor.rabbitmq

Class OutboundMessageResult<OMSG extends OutboundMessage>

java.lang.Object

reactor.rabbitmq.OutboundMessageResult<OMSG>

public class OutboundMessageResult<OMSG extends OutboundMessage>
extends Object

Result of a sent message when using publisher confirm.

Constructor Summary

Constructors

Constructor and Description
OutboundMessageResult(OMSG outboundMessage, boolean ack) Constructs a result which is described by the initial message that has been published and the acknowledgment status.
OutboundMessageResult(OMSG outboundMessage, boolean ack, boolean returned) Constructs a result which is described by the initial message that has been published, the acknowledgment status, and the returned status.

Method Summary

Modifier and Type	Method and Description
OMSG	getOutboundMessage() Defines the message that has been published.
boolean	isAck() Defines whether the message has been acknowledged by the broker or not.
boolean	isReturned() Defines whether the message has been returned by the broker or not.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

OutboundMessageResult

public OutboundMessageResult(OMSG outboundMessage,
                             boolean ack)

Constructs a result which is described by the initial message that has been published and the acknowledgment status.

Parameters:

outboundMessage - The message that has been published

ack - Whether the message has been acknowledged by the broker or not

OutboundMessageResult

public OutboundMessageResult(OMSG outboundMessage,
                             boolean ack,
                             boolean returned)

Constructs a result which is described by the initial message that has been published, the acknowledgment status, and the returned status.

Parameters:

outboundMessage - The message that has been published

ack - Whether the message has been acknowledged by the broker or not

returned - Whether the message was undeliverable and hence returned

Method Detail

getOutboundMessage

public OMSG getOutboundMessage()

Defines the message that has been published.

Returns:

The message that has been published.

isAck

public boolean isAck()

Defines whether the message has been acknowledged by the broker or not. The message may still be confirmed if it could not be routed to the correct queue. This can be validated with the isReturned method.

Returns:

True if the message has been acknowledged, false otherwise.

isReturned

public boolean isReturned()

Defines whether the message has been returned by the broker or not.

Returns:

True if the message was undeliverable and has returned, false otherwise.

Since:

1.3.0

toString

public String toString()

Overrides:

toString in class Object