Package org.acemq.amqp.transport

Class ConfirmResult

java.lang.Object

org.acemq.amqp.transport.ConfirmResult

public final class ConfirmResult
extends Object

The broker's answer to one publish.

Method Summary

Modifier and Type	Method	Description
static ConfirmResult	confirmed(Duration latency)	The broker took responsibility for the message and something was bound to receive it.
@Nullable String	detail()
static ConfirmResult	failed(Duration latency, @Nullable String detail)	The broker refused the message or never answered.
boolean	isConfirmed()
boolean	isRouted()
Duration	latency()
String	toString()
static ConfirmResult	unroutable(Duration latency, @Nullable String detail)	The broker took responsibility for the message but nothing was bound to receive it.

Methods inherited from class java.lang.Object

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

Method Details

confirmed

public static ConfirmResult confirmed(Duration latency)

The broker took responsibility for the message and something was bound to receive it.

unroutable

public static ConfirmResult unroutable(Duration latency,
 @Nullable String detail)

The broker took responsibility for the message but nothing was bound to receive it.

Reported separately from a failure because the publish did succeed; whether an unroutable message is an error is the core's decision, not the transport's.

failed

public static ConfirmResult failed(Duration latency,
 @Nullable String detail)

The broker refused the message or never answered.

isConfirmed

public boolean isConfirmed()

isRouted

public boolean isRouted()

latency

public Duration latency()

detail

public @Nullable String detail()

Returns:

why the publish was unroutable or failed, when the broker said

toString

public String toString()

Overrides:

toString in class Object