public class PendingConfirm extends Object
CorrelationData for
the client to correlate a confirm with a sent message.| Constructor and Description |
|---|
PendingConfirm(CorrelationData correlationData,
long timestamp) |
| Modifier and Type | Method and Description |
|---|---|
void |
countDown()
Count down the returned message latch; call after the listener has been called.
|
String |
getCause() |
CorrelationData |
getCorrelationData()
The correlation data supplied by the client when sending the message
corresponding to this confirmation.
|
long |
getTimestamp() |
boolean |
isReturned()
True if a returned message has been received.
|
void |
setCause(String cause)
When the confirmation is nacked, set the cause when available.
|
void |
setReturned(boolean isReturned)
Indicate that a returned message has been received.
|
String |
toString() |
boolean |
waitForReturnIfNeeded()
Return true if a return has been passed to the listener or if no return has been
received.
|
public PendingConfirm(@Nullable CorrelationData correlationData, long timestamp)
correlationData - The correlation data.timestamp - The timestamp.@Nullable public CorrelationData getCorrelationData()
public long getTimestamp()
public void setCause(String cause)
cause - The cause.public boolean isReturned()
public void setReturned(boolean isReturned)
isReturned - true if there is a return.public boolean waitForReturnIfNeeded()
throws InterruptedException
InterruptedException - if interrupted.public void countDown()