public abstract class MessageDelivery extends WatchBase
Constructor and Description |
---|
MessageDelivery(org.fusesource.hawtbuf.Buffer encoded) |
MessageDelivery(Message message) |
MessageDelivery(Message message,
org.fusesource.hawtbuf.Buffer encoded) |
Modifier and Type | Method and Description |
---|---|
org.fusesource.hawtbuf.Buffer |
encoded() |
protected void |
fireWatches() |
DeliveryState |
getLocalState() |
Message |
getMessage() |
DeliveryState |
getRemoteState() |
DeliveryState |
getRemoteStateChange() |
Future<DeliveryState> |
getRemoteStateChangeFuture() |
DeliveryState |
getSettle() |
Future<DeliveryState> |
getSettleFuture() |
boolean |
isSettled() |
void |
onEncoded(Callback<Void> cb) |
void |
onRemoteStateChange(Callback<DeliveryState> cb) |
void |
onSettle(Callback<DeliveryState> cb) |
void |
redeliver(boolean incrementDeliveryCounter) |
void |
settle() |
public Delivery delivery
public MessageDelivery(Message message)
public MessageDelivery(org.fusesource.hawtbuf.Buffer encoded)
public MessageDelivery(Message message, org.fusesource.hawtbuf.Buffer encoded)
public Message getMessage()
public org.fusesource.hawtbuf.Buffer encoded()
public boolean isSettled()
public DeliveryState getRemoteState()
public DeliveryState getLocalState()
public DeliveryState getRemoteStateChange() throws Exception
Exception
public Future<DeliveryState> getRemoteStateChangeFuture()
public void onRemoteStateChange(Callback<DeliveryState> cb)
public DeliveryState getSettle() throws Exception
Exception
public Future<DeliveryState> getSettleFuture()
public void onSettle(Callback<DeliveryState> cb)
protected void fireWatches()
fireWatches
in class WatchBase
public void redeliver(boolean incrementDeliveryCounter)
public void settle()
Copyright © 2016 The Apache Software Foundation. All rights reserved.