org.apache.qpid.server.protocol.v1_0

Class SendingLink_1_0

java.lang.Object

org.apache.qpid.server.protocol.v1_0.SendingLink_1_0

All Implemented Interfaces:

DeliveryStateHandler, LinkEventListener, SendingLinkListener, LinkModel, Link_1_0

public class SendingLink_1_0
extends Object
implements SendingLinkListener, Link_1_0, DeliveryStateHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.amqp_1_0.transport.SendingLinkListener

SendingLinkListener.DefaultLinkEventListener

Field Summary

Fields inherited from interface org.apache.qpid.amqp_1_0.transport.SendingLinkListener

DEFAULT

Constructor Summary

Constructors

Constructor and Description
SendingLink_1_0(SendingLinkAttachment linkAttachment, VirtualHostImpl vhost, SendingDestination destination)

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

SendingLink_1_0

public SendingLink_1_0(SendingLinkAttachment linkAttachment,
                       VirtualHostImpl vhost,
                       SendingDestination destination)
                throws AmqpErrorException

Throws:

AmqpErrorException

Method Detail

resume

public void resume(SendingLinkAttachment linkAttachment)

remoteDetached

public void remoteDetached(LinkEndpoint endpoint,
                           Detach detach)

Specified by:

remoteDetached in interface LinkEventListener

start

public void start()

Specified by:

start in interface Link_1_0

getEndpoint

public SendingLinkEndpoint getEndpoint()

getSession

public Session_1_0 getSession()

flowStateChanged

public void flowStateChanged()

Specified by:

flowStateChanged in interface SendingLinkListener

isDraining

public boolean isDraining()

drained

public boolean drained()

addUnsettled

public void addUnsettled(Binary tag,
                         UnsettledAction unsettledAction,
                         MessageInstance queueEntry)

removeUnsettled

public void removeUnsettled(Binary tag)

handle

public void handle(Binary deliveryTag,
                   DeliveryState state,
                   Boolean settled)

Specified by:

handle in interface DeliveryStateHandler

getTransactionId

public Binary getTransactionId()

getLock

public Object getLock()

isDetached

public boolean isDetached()

isAttached

public boolean isAttached()

setLinkAttachment

public void setLinkAttachment(SendingLinkAttachment linkAttachment)

getUnsettledOutcomeMap

public Map getUnsettledOutcomeMap()

setCloseAction

public void setCloseAction(Runnable action)

getVirtualHost

public VirtualHostImpl getVirtualHost()

getConsumer

public ConsumerImpl getConsumer()

getConsumerTarget

public org.apache.qpid.server.protocol.v1_0.ConsumerTarget_1_0 getConsumerTarget()