Package com.swiftmq.impl.amqp.amqp.v01_00_00

Class TargetLink

java.lang.Object

com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink

com.swiftmq.impl.amqp.amqp.v01_00_00.TargetLink

All Implemented Interfaces:

QueueSenderProvider, ResourceProvider, DestinationFactory

public class TargetLink
extends ServerLink
implements QueueSenderProvider, DestinationFactory

Constructor Summary

Constructors

Constructor	Description
TargetLink(SwiftletContext ctx, SessionHandler mySessionHandler, String name, int rcvSettleMode)

Method Summary

Modifier and Type	Method	Description
void	abortCurrentMessage()
boolean	addTransferFrame(TransferFrame frame)
void	close()
void	closeResource()
Destination	create(AddressIF addressIF)
void	decreaseActiveTransactions()
void	fillUsage()
long	getCurrentMessageSize()
long	getDeliveryCount()
long	getFlowcontrolDelay()
FlowcontrolTimer	getFlowcontrolTimer()
DeliveryNumber	getLastDeliveryId()
DeliveryStateIF	getLastDeliveryState()
long	getLinkCredit()
AMQPArray	getOfferedCapabilitiesArray()
String	getQueueName()
QueueSender	getQueueSender()
int	getRcvSettleMode()
void	increaseActiveTransactions()
boolean	isCoordinator()
void	setCoordinator(boolean coordinator)
void	setDeliveryCount(long deliveryCount)
void	setFlowcontrolDelay(long flowcontrolDelay)
void	setFlowcontrolTimer(FlowcontrolTimer flowcontrolTimer)
void	setLocalAddress(AddressIF localAddress)
protected void	setRemoteAddress(AddressIF remoteAddress)
void	setRemoteUnsettled(Map remoteUnsettled)
void	settle(long deliveryId, DeliveryStateIF deliveryState)
void	setUsage(Entity usage)
String	toString()
void	verifyLocalAddress()
void	visit(AddressString addressString)

Methods inherited from class com.swiftmq.impl.amqp.amqp.v01_00_00.ServerLink

getDesiredCapabilities, getHandle, getLocalAddress, getLocalDestination, getMySessionHandler, getName, getOfferedCapabilities, getRemoteAddress, getRemoteHandle, getWaitingPO, isClosed, isDynamic, setDesiredCapabilities, setDynamic, setHandle, setOfferedCapabilities, setRemoteHandle, setWaitingPO

Methods inherited from class java.lang.Object

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

Constructor Details

TargetLink

public TargetLink(SwiftletContext ctx,
 SessionHandler mySessionHandler,
 String name,
 int rcvSettleMode)

Method Details

setUsage

public void setUsage(Entity usage)

Specified by:

setUsage in class ServerLink

fillUsage

public void fillUsage()

Specified by:

fillUsage in class ServerLink

setLocalAddress

public void setLocalAddress(AddressIF localAddress)

Overrides:

setLocalAddress in class ServerLink

setRemoteAddress

protected void setRemoteAddress(AddressIF remoteAddress)

Overrides:

setRemoteAddress in class ServerLink

getLinkCredit

public long getLinkCredit()

setFlowcontrolDelay

public void setFlowcontrolDelay(long flowcontrolDelay)

getFlowcontrolDelay

public long getFlowcontrolDelay()

getFlowcontrolTimer

public FlowcontrolTimer getFlowcontrolTimer()

setFlowcontrolTimer

public void setFlowcontrolTimer(FlowcontrolTimer flowcontrolTimer)

setDeliveryCount

public void setDeliveryCount(long deliveryCount)

getDeliveryCount

public long getDeliveryCount()

getRcvSettleMode

public int getRcvSettleMode()

isCoordinator

public boolean isCoordinator()

setCoordinator

public void setCoordinator(boolean coordinator)

setRemoteUnsettled

public void setRemoteUnsettled(Map remoteUnsettled)

getOfferedCapabilitiesArray

public AMQPArray getOfferedCapabilitiesArray()

visit

public void visit(AddressString addressString)

create

public Destination create(AddressIF addressIF)

Specified by:

create in interface DestinationFactory

verifyLocalAddress

public void verifyLocalAddress()
                        throws AuthenticationException,
QueueException,
TopicException,
InvalidSelectorException

Overrides:

verifyLocalAddress in class ServerLink

Throws:

AuthenticationException

QueueException

TopicException

InvalidSelectorException

getLastDeliveryState

public DeliveryStateIF getLastDeliveryState()

getLastDeliveryId

public DeliveryNumber getLastDeliveryId()

getCurrentMessageSize

public long getCurrentMessageSize()

abortCurrentMessage

public void abortCurrentMessage()

getQueueSender

public QueueSender getQueueSender()

Specified by:

getQueueSender in interface QueueSenderProvider

getQueueName

public String getQueueName()

increaseActiveTransactions

public void increaseActiveTransactions()

Specified by:

increaseActiveTransactions in interface ResourceProvider

decreaseActiveTransactions

public void decreaseActiveTransactions()

Specified by:

decreaseActiveTransactions in interface ResourceProvider

closeResource

public void closeResource()

Specified by:

closeResource in interface ResourceProvider

addTransferFrame

public boolean addTransferFrame(TransferFrame frame)
                         throws EndWithErrorException

Throws:

EndWithErrorException

settle

public void settle(long deliveryId,
 DeliveryStateIF deliveryState)
            throws EndWithErrorException

Specified by:

settle in class ServerLink

Throws:

EndWithErrorException

close

public void close()

Overrides:

close in class ServerLink

toString

public String toString()

Overrides:

toString in class Object