public class SendingLink_1_0 extends Object implements SendingLinkListener, Link_1_0, DeliveryStateHandler
SendingLinkListener.DefaultLinkEventListener
DEFAULT
Constructor and Description |
---|
SendingLink_1_0(SendingLinkAttachment linkAttachment,
VirtualHostImpl vhost,
SendingDestination destination) |
Modifier and Type | Method and Description |
---|---|
void |
addUnsettled(Binary tag,
UnsettledAction unsettledAction,
MessageInstance queueEntry) |
boolean |
drained() |
void |
flowStateChanged() |
ConsumerImpl |
getConsumer() |
org.apache.qpid.server.protocol.v1_0.ConsumerTarget_1_0 |
getConsumerTarget() |
SendingLinkEndpoint |
getEndpoint() |
Object |
getLock() |
Session_1_0 |
getSession() |
Binary |
getTransactionId() |
Map |
getUnsettledOutcomeMap() |
VirtualHostImpl |
getVirtualHost() |
void |
handle(Binary deliveryTag,
DeliveryState state,
Boolean settled) |
boolean |
isAttached() |
boolean |
isDetached() |
boolean |
isDraining() |
void |
remoteDetached(LinkEndpoint endpoint,
Detach detach) |
void |
removeUnsettled(Binary tag) |
void |
resume(SendingLinkAttachment linkAttachment) |
void |
setCloseAction(Runnable action) |
void |
setLinkAttachment(SendingLinkAttachment linkAttachment) |
void |
start() |
public SendingLink_1_0(SendingLinkAttachment linkAttachment, VirtualHostImpl vhost, SendingDestination destination) throws AmqpErrorException
AmqpErrorException
public void resume(SendingLinkAttachment linkAttachment)
public void remoteDetached(LinkEndpoint endpoint, Detach detach)
remoteDetached
in interface LinkEventListener
public SendingLinkEndpoint getEndpoint()
public Session_1_0 getSession()
public void flowStateChanged()
flowStateChanged
in interface SendingLinkListener
public boolean isDraining()
public boolean drained()
public void addUnsettled(Binary tag, UnsettledAction unsettledAction, MessageInstance queueEntry)
public void removeUnsettled(Binary tag)
public void handle(Binary deliveryTag, DeliveryState state, Boolean settled)
handle
in interface DeliveryStateHandler
public Binary getTransactionId()
public Object getLock()
public boolean isDetached()
public boolean isAttached()
public void setLinkAttachment(SendingLinkAttachment linkAttachment)
public Map getUnsettledOutcomeMap()
public void setCloseAction(Runnable action)
public VirtualHostImpl getVirtualHost()
public ConsumerImpl getConsumer()
public org.apache.qpid.server.protocol.v1_0.ConsumerTarget_1_0 getConsumerTarget()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.