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, com.swiftmq.swiftlet.queue.MessageIndex messageIndex)
void	addUnsettled(long deliveryId, com.swiftmq.swiftlet.queue.MessageIndex messageIndex, long size)
void	advanceDeliveryCount()
void	autoack(com.swiftmq.swiftlet.queue.MessageIndex messageIndex)
void	clearMessageProcessor()
void	close()
void	closeResource()
void	decreaseActiveTransactions()
void	fillUsage()
long	getAvailable()
com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF	getCurrentTx()
com.swiftmq.amqp.v100.generated.messaging.delivery_state.OutcomeIF	getDefaultOutcome()
long	getDeliveryCountSnd()
com.swiftmq.amqp.v100.generated.messaging.addressing.TerminusDurability	getDurability()
com.swiftmq.amqp.v100.generated.messaging.addressing.TerminusExpiryPolicy	getExpiryPolicy()
long	getLastReceivedLinkCredit()
long	getLinkCredit()
String	getQueueName()
com.swiftmq.swiftlet.queue.QueueReceiver	getQueueReceiver()
int	getSndSettleMode()
com.swiftmq.amqp.v100.types.AMQPArray	getSupportedOutcomes()
OutboundTransformer	getTransformer()
void	incDeliveryCountSnd()
void	increaseActiveTransactions()
boolean	isDrain()
boolean	isFlowAfterDrainRequired()
boolean	isMessageProcessorRunning()
void	setCurrentTx(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF currentTx)
void	setDefaultOutcome(com.swiftmq.amqp.v100.generated.messaging.delivery_state.OutcomeIF defaultOutcome)
void	setDeliveryCountRcv(long deliveryCountRcv)
void	setDrain(boolean drain)
void	setDurability(com.swiftmq.amqp.v100.generated.messaging.addressing.TerminusDurability durability)
void	setExpiryPolicy(com.swiftmq.amqp.v100.generated.messaging.addressing.TerminusExpiryPolicy expiryPolicy)
void	setFlowAfterDrainRequired(boolean flowAfterDrainRequired)
void	setLinkCredit(long linkCredit)
void	setLocalAddress(com.swiftmq.amqp.v100.generated.messaging.message_format.AddressIF localAddress)
void	setMessageSelector(String messageSelector)
void	setNoLocal(boolean noLocal)
protected void	setRemoteAddress(com.swiftmq.amqp.v100.generated.messaging.message_format.AddressIF remoteAddress)
void	setRemoteUnsettled(Map remoteUnsettled)
void	settle(long deliveryId, com.swiftmq.amqp.v100.generated.messaging.delivery_state.DeliveryStateIF deliveryState)
void	setUsage(com.swiftmq.mgmt.Entity usage)
void	startMessageProcessor()
void	startMessageProcessor(SourceMessageProcessor messageProcessor)
void	stopMessageProcessor()
String	toString()
void	verifyLocalAddress()

Methods inherited from class ServerLink

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

Methods inherited from class 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(com.swiftmq.mgmt.Entity usage)

Specified by:

setUsage in class ServerLink

fillUsage

public void fillUsage()

Specified by:

fillUsage in class ServerLink

setLocalAddress

public void setLocalAddress(com.swiftmq.amqp.v100.generated.messaging.message_format.AddressIF localAddress)

Overrides:

setLocalAddress in class ServerLink

setRemoteAddress

protected void setRemoteAddress(com.swiftmq.amqp.v100.generated.messaging.message_format.AddressIF remoteAddress)

Overrides:

setRemoteAddress in class ServerLink

getSupportedOutcomes

public com.swiftmq.amqp.v100.types.AMQPArray getSupportedOutcomes()

setDefaultOutcome

public void setDefaultOutcome(com.swiftmq.amqp.v100.generated.messaging.delivery_state.OutcomeIF defaultOutcome)

getDefaultOutcome

public com.swiftmq.amqp.v100.generated.messaging.delivery_state.OutcomeIF getDefaultOutcome()

getSndSettleMode

public int getSndSettleMode()

getLinkCredit

public long getLinkCredit()

getLastReceivedLinkCredit

public long getLastReceivedLinkCredit()

setLinkCredit

public void setLinkCredit(long linkCredit)

getExpiryPolicy

public com.swiftmq.amqp.v100.generated.messaging.addressing.TerminusExpiryPolicy getExpiryPolicy()

setExpiryPolicy

public void setExpiryPolicy(com.swiftmq.amqp.v100.generated.messaging.addressing.TerminusExpiryPolicy expiryPolicy)

getDurability

public com.swiftmq.amqp.v100.generated.messaging.addressing.TerminusDurability getDurability()

setDurability

public void setDurability(com.swiftmq.amqp.v100.generated.messaging.addressing.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 com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF getCurrentTx()

setCurrentTx

public void setCurrentTx(com.swiftmq.amqp.v100.generated.transactions.coordination.TxnIdIF currentTx)

startMessageProcessor

public void startMessageProcessor()
                           throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

startMessageProcessor

public void startMessageProcessor(SourceMessageProcessor messageProcessor)
                           throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

clearMessageProcessor

public void clearMessageProcessor()

isMessageProcessorRunning

public boolean isMessageProcessorRunning()

stopMessageProcessor

public void stopMessageProcessor()
                          throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.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 com.swiftmq.swiftlet.auth.AuthenticationException,
com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.topic.TopicException,
javax.jms.InvalidSelectorException

Overrides:

verifyLocalAddress in class ServerLink

Throws:

com.swiftmq.swiftlet.auth.AuthenticationException

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.topic.TopicException

javax.jms.InvalidSelectorException

getQueueReceiver

public com.swiftmq.swiftlet.queue.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,
 com.swiftmq.swiftlet.queue.MessageIndex messageIndex,
 long size)

addUnsettled

public void addUnsettled(long deliveryId,
 com.swiftmq.swiftlet.queue.MessageIndex messageIndex)

settle

public void settle(long deliveryId,
 com.swiftmq.amqp.v100.generated.messaging.delivery_state.DeliveryStateIF deliveryState)
            throws EndWithErrorException

Specified by:

settle in class ServerLink

Throws:

EndWithErrorException

autoack

public void autoack(com.swiftmq.swiftlet.queue.MessageIndex messageIndex)
             throws com.swiftmq.swiftlet.queue.QueueException

Throws:

com.swiftmq.swiftlet.queue.QueueException

close

public void close()

Overrides:

close in class ServerLink

toString

public String toString()

Overrides:

toString in class Object