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

Class SourceLink

java.lang.Object

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

com.swiftmq.impl.amqp.amqp.v01_00_00.SourceLink

All Implemented Interfaces:

QueueReceiverProvider, ResourceProvider

public class SourceLink
extends ServerLink
implements QueueReceiverProvider

Constructor Summary

Constructors

Constructor	Description
SourceLink(SwiftletContext ctx, SessionHandler mySessionHandler, String name, int sndSettleMode)

Method Summary

Modifier and Type	Method	Description
void	addUnsettled(long deliveryId, MessageIndex messageIndex)
void	addUnsettled(long deliveryId, MessageIndex messageIndex, long size)
void	advanceDeliveryCount()
void	autoack(MessageIndex messageIndex)
void	clearMessageProcessor()
void	close()
void	closeResource()
void	decreaseActiveTransactions()
void	fillUsage()
long	getAvailable()
TxnIdIF	getCurrentTx()
OutcomeIF	getDefaultOutcome()
long	getDeliveryCountSnd()
TerminusDurability	getDurability()
TerminusExpiryPolicy	getExpiryPolicy()
long	getLastReceivedLinkCredit()
long	getLinkCredit()
String	getQueueName()
QueueReceiver	getQueueReceiver()
int	getSndSettleMode()
AMQPArray	getSupportedOutcomes()
OutboundTransformer	getTransformer()
void	incDeliveryCountSnd()
void	increaseActiveTransactions()
boolean	isDrain()
boolean	isFlowAfterDrainRequired()
boolean	isMessageProcessorRunning()
void	setCurrentTx(TxnIdIF currentTx)
void	setDefaultOutcome(OutcomeIF defaultOutcome)
void	setDeliveryCountRcv(long deliveryCountRcv)
void	setDrain(boolean drain)
void	setDurability(TerminusDurability durability)
void	setExpiryPolicy(TerminusExpiryPolicy expiryPolicy)
void	setFlowAfterDrainRequired(boolean flowAfterDrainRequired)
void	setLinkCredit(long linkCredit)
void	setLocalAddress(AddressIF localAddress)
void	setMessageSelector(String messageSelector)
void	setNoLocal(boolean noLocal)
protected void	setRemoteAddress(AddressIF remoteAddress)
void	setRemoteUnsettled(Map remoteUnsettled)
void	settle(long deliveryId, DeliveryStateIF deliveryState)
void	setUsage(Entity usage)
void	startMessageProcessor()
void	startMessageProcessor(SourceMessageProcessor messageProcessor)
void	stopMessageProcessor()
String	toString()
void	verifyLocalAddress()

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

SourceLink

public SourceLink(SwiftletContext ctx,
 SessionHandler mySessionHandler,
 String name,
 int sndSettleMode)

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

getSupportedOutcomes

public AMQPArray getSupportedOutcomes()

setDefaultOutcome

public void setDefaultOutcome(OutcomeIF defaultOutcome)

getDefaultOutcome

public OutcomeIF getDefaultOutcome()

getSndSettleMode

public int getSndSettleMode()

getLinkCredit

public long getLinkCredit()

getLastReceivedLinkCredit

public long getLastReceivedLinkCredit()

setLinkCredit

public void setLinkCredit(long linkCredit)

getExpiryPolicy

public TerminusExpiryPolicy getExpiryPolicy()

setExpiryPolicy

public void setExpiryPolicy(TerminusExpiryPolicy expiryPolicy)

getDurability

public TerminusDurability getDurability()

setDurability

public void setDurability(TerminusDurability durability)

setNoLocal

public void setNoLocal(boolean noLocal)

setMessageSelector

public void setMessageSelector(String messageSelector)

setRemoteUnsettled

public void setRemoteUnsettled(Map remoteUnsettled)

getQueueName

public String getQueueName()

getCurrentTx

public TxnIdIF getCurrentTx()

setCurrentTx

public void setCurrentTx(TxnIdIF currentTx)

startMessageProcessor

public void startMessageProcessor()
                           throws QueueException

Throws:

QueueException

startMessageProcessor

public void startMessageProcessor(SourceMessageProcessor messageProcessor)
                           throws QueueException

Throws:

QueueException

clearMessageProcessor

public void clearMessageProcessor()

isMessageProcessorRunning

public boolean isMessageProcessorRunning()

stopMessageProcessor

public void stopMessageProcessor()
                          throws QueueException

Throws:

QueueException

getTransformer

public OutboundTransformer getTransformer()
                                   throws EndWithErrorException

Throws:

EndWithErrorException

getAvailable

public long getAvailable()

getDeliveryCountSnd

public long getDeliveryCountSnd()

setDeliveryCountRcv

public void setDeliveryCountRcv(long deliveryCountRcv)

incDeliveryCountSnd

public void incDeliveryCountSnd()

isDrain

public boolean isDrain()

setDrain

public void setDrain(boolean drain)

isFlowAfterDrainRequired

public boolean isFlowAfterDrainRequired()

setFlowAfterDrainRequired

public void setFlowAfterDrainRequired(boolean flowAfterDrainRequired)

advanceDeliveryCount

public void advanceDeliveryCount()

verifyLocalAddress

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

Overrides:

verifyLocalAddress in class ServerLink

Throws:

AuthenticationException

QueueException

TopicException

InvalidSelectorException

getQueueReceiver

public QueueReceiver getQueueReceiver()

Specified by:

getQueueReceiver in interface QueueReceiverProvider

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

addUnsettled

public void addUnsettled(long deliveryId,
 MessageIndex messageIndex,
 long size)

addUnsettled

public void addUnsettled(long deliveryId,
 MessageIndex messageIndex)

settle

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

Specified by:

settle in class ServerLink

Throws:

EndWithErrorException

autoack

public void autoack(MessageIndex messageIndex)
             throws QueueException

Throws:

QueueException

close

public void close()

Overrides:

close in class ServerLink

toString

public String toString()

Overrides:

toString in class Object