public class AckFuture extends java.util.concurrent.FutureTask<IAcknowledgement>
Constructor and Description |
---|
AckFuture(long requestId) |
AckFuture(long requestId,
boolean isDoneAlready) |
Modifier and Type | Method and Description |
---|---|
protected void |
done() |
long |
getRequestMessageId() |
boolean |
hasBeenAcknowledged() |
boolean |
isDone() |
void |
setAcknowledgement(IAcknowledgement ack) |
public AckFuture(long requestId)
public AckFuture(long requestId, boolean isDoneAlready)
public long getRequestMessageId()
public void setAcknowledgement(IAcknowledgement ack)
public boolean isDone()
isDone
in interface java.util.concurrent.Future<IAcknowledgement>
isDone
in class java.util.concurrent.FutureTask<IAcknowledgement>
protected void done()
done
in class java.util.concurrent.FutureTask<IAcknowledgement>
public boolean hasBeenAcknowledged()