Class QueueManagerImpl

java.lang.Object

com.swiftmq.swiftlet.Swiftlet

com.swiftmq.swiftlet.queue.QueueManager

com.swiftmq.impl.queue.standard.QueueManagerImpl

All Implemented Interfaces:

com.swiftmq.swiftlet.timer.event.TimerListener, EventListener

public class QueueManagerImpl
extends com.swiftmq.swiftlet.queue.QueueManager
implements com.swiftmq.swiftlet.timer.event.TimerListener

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLUSTER_TOPIC
static final String	DLQ
static final String	PREFIX_TEMP_QUEUE
static final String	PROP_ACACHE_SIZE
static final String	PROP_ACACHE_SIZE_KB
static final String	PROP_ACLEANUP_INTERVAL
static final String	PROP_AFLOWCONTROL_QUEUE_SIZE
static final String	PROP_AMESSAGES_MAXIMUM
static final String	PROP_CACHE_SIZE
static final String	PROP_CACHE_SIZE_BYTES_KB
static final String	PROP_CLEANUP_INTERVAL
static final String	PROP_COLLECT_INTERVAL
static final String	PROP_CONSUMER
static final String	PROP_DELIVER_EXPIRED
static final String	PROP_DUPLICATE_DETECTION_BACKLOG_SIZE
static final String	PROP_DUPLICATE_DETECTION_ENABLED
static final String	PROP_FLOWCONTROL_DELAY
static final String	PROP_FLOWCONTROL_QUEUE_SIZE
static final String	PROP_LATENCY
static final String	PROP_LOG_DUPLICATES
static final String	PROP_LOG_EXPIRED
static final String	PROP_MAX_FLOWCONTROL_DELAY
static final String	PROP_MCACHE_MESSAGES
static final String	PROP_MCACHE_SIZE_KB
static final String	PROP_MESSAGECOUNT
static final String	PROP_MESSAGES_MAXIMUM
static final String	PROP_MSG_CONSUME_RATE
static final String	PROP_MSG_PRODUCE_RATE
static final String	PROP_MULTI_QUEUE_TX_GLOBAL_LOCK
static final String	PROP_PERSISTENCE
static final String	PROP_TOTAL_CONSUMED
static final String	PROP_TOTAL_PRODUCED
static final char	SYSTEM_QUEUE_CHAR
static final int[]	VERSIONS

Fields inherited from class com.swiftmq.swiftlet.queue.QueueManager

multiQueueLock, useGlobalLocking

Fields inherited from class com.swiftmq.swiftlet.Swiftlet

STATE_ACTIVE, STATE_INACTIVE, STATE_STANDBY

Constructor Summary

Constructors

Constructor	Description
QueueManagerImpl()

Method Summary

Modifier and Type	Method	Description
void	addQueueManagerListener(com.swiftmq.swiftlet.queue.event.QueueManagerListener l)
void	addQueueManagerListener(String queueName, com.swiftmq.swiftlet.queue.event.QueueManagerListener l)
protected CacheTableFactory	createCacheTableFactory()
MessageGroupDispatchPolicyFactory	createMessaageGroupDispatchPolicyFactory()
protected MessageQueueFactory	createMessageQueueFactory()
void	createQueue(String queueName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
void	createQueue(String queueName, com.swiftmq.swiftlet.queue.QueueFactory factory)
com.swiftmq.swiftlet.queue.QueueBrowser	createQueueBrowser(String queueName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin, com.swiftmq.swiftlet.queue.Selector selector)
com.swiftmq.swiftlet.queue.QueueReceiver	createQueueReceiver(String queueName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin, com.swiftmq.swiftlet.queue.Selector selector)
com.swiftmq.swiftlet.queue.QueueSender	createQueueSender(String queueName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
protected RegularQueueFactory	createRegularQueueFactory()
protected SwiftletContext	createSwiftletContext(com.swiftmq.mgmt.Configuration config)
protected SystemQueueFactory	createSystemQueueFactory()
String	createTemporaryQueue()
protected TempQueueFactory	createTempQueueFactory()
void	deleteQueue(String queueName, boolean onEmpty)
void	deleteTemporaryQueue(String queueName)
String	fqn(String queueName)
String[]	getDefinedQueueNames()
long	getMaxFlowControlDelay()
com.swiftmq.swiftlet.queue.AbstractQueue	getQueueForInternalUse(String queueName)
com.swiftmq.swiftlet.queue.AbstractQueue	getQueueForInternalUse(String queueName, boolean respectRedirection)
boolean	isDeliverExpired()
boolean	isLogDuplicates()
boolean	isLogExpired()
boolean	isQueueDefined(String queueName)
boolean	isQueueRunning(String queueName)
boolean	isSystemQueue(String queueName)
boolean	isTemporaryQueue(String queueName)
void	performTimeAction()
void	purgeQueue(String queueName)
void	removeQueueManagerListener(com.swiftmq.swiftlet.queue.event.QueueManagerListener l)
void	removeQueueManagerListener(String queueName, com.swiftmq.swiftlet.queue.event.QueueManagerListener l)
void	setQueueInboundRedirector(String likePredicate, String inboundQueueName)
void	setQueueOutboundRedirector(String likePredicate, String outboundQueueName)
protected void	shutdown()
protected void	startCluster()
protected void	startup(com.swiftmq.mgmt.Configuration config)
String	stripLocalName(String name)

Methods inherited from class com.swiftmq.swiftlet.queue.QueueManager

isUseGlobaLocking, lockMultiQueue, setUseGlobalLocking, unlockMultiQueue

Methods inherited from class com.swiftmq.swiftlet.Swiftlet

getName, getStartupTime, getState, isSnapshotAvailable, resume, setStartupTime, standby

Methods inherited from class Object

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

Field Details

DLQ

public static final String DLQ

See Also:

• Constant Field Values

CLUSTER_TOPIC

public static final String CLUSTER_TOPIC

See Also:

• Constant Field Values

VERSIONS

public static final int[] VERSIONS

PROP_LOG_EXPIRED

public static final String PROP_LOG_EXPIRED

See Also:

• Constant Field Values

PROP_LOG_DUPLICATES

public static final String PROP_LOG_DUPLICATES

See Also:

• Constant Field Values

PROP_DELIVER_EXPIRED

public static final String PROP_DELIVER_EXPIRED

See Also:

• Constant Field Values

PROP_CLEANUP_INTERVAL

public static final String PROP_CLEANUP_INTERVAL

See Also:

• Constant Field Values

PROP_COLLECT_INTERVAL

public static final String PROP_COLLECT_INTERVAL

See Also:

• Constant Field Values

PROP_MESSAGES_MAXIMUM

public static final String PROP_MESSAGES_MAXIMUM

See Also:

• Constant Field Values

PROP_PERSISTENCE

public static final String PROP_PERSISTENCE

See Also:

• Constant Field Values

PROP_MAX_FLOWCONTROL_DELAY

public static final String PROP_MAX_FLOWCONTROL_DELAY

See Also:

• Constant Field Values

PROP_FLOWCONTROL_QUEUE_SIZE

public static final String PROP_FLOWCONTROL_QUEUE_SIZE

See Also:

• Constant Field Values

PROP_ACACHE_SIZE

public static final String PROP_ACACHE_SIZE

See Also:

• Constant Field Values

PROP_ACACHE_SIZE_KB

public static final String PROP_ACACHE_SIZE_KB

See Also:

• Constant Field Values

PROP_ACLEANUP_INTERVAL

public static final String PROP_ACLEANUP_INTERVAL

See Also:

• Constant Field Values

PROP_AFLOWCONTROL_QUEUE_SIZE

public static final String PROP_AFLOWCONTROL_QUEUE_SIZE

See Also:

• Constant Field Values

PROP_AMESSAGES_MAXIMUM

public static final String PROP_AMESSAGES_MAXIMUM

See Also:

• Constant Field Values

PROP_LATENCY

public static final String PROP_LATENCY

See Also:

• Constant Field Values

PROP_MCACHE_MESSAGES

public static final String PROP_MCACHE_MESSAGES

See Also:

• Constant Field Values

PROP_MCACHE_SIZE_KB

public static final String PROP_MCACHE_SIZE_KB

See Also:

• Constant Field Values

PROP_MESSAGECOUNT

public static final String PROP_MESSAGECOUNT

See Also:

• Constant Field Values

PROP_MSG_CONSUME_RATE

public static final String PROP_MSG_CONSUME_RATE

See Also:

• Constant Field Values

PROP_MSG_PRODUCE_RATE

public static final String PROP_MSG_PRODUCE_RATE

See Also:

• Constant Field Values

PROP_TOTAL_CONSUMED

public static final String PROP_TOTAL_CONSUMED

See Also:

• Constant Field Values

PROP_TOTAL_PRODUCED

public static final String PROP_TOTAL_PRODUCED

See Also:

• Constant Field Values

PROP_FLOWCONTROL_DELAY

public static final String PROP_FLOWCONTROL_DELAY

See Also:

• Constant Field Values

PROP_DUPLICATE_DETECTION_ENABLED

public static final String PROP_DUPLICATE_DETECTION_ENABLED

See Also:

• Constant Field Values

PROP_DUPLICATE_DETECTION_BACKLOG_SIZE

public static final String PROP_DUPLICATE_DETECTION_BACKLOG_SIZE

See Also:

• Constant Field Values

PROP_MULTI_QUEUE_TX_GLOBAL_LOCK

public static final String PROP_MULTI_QUEUE_TX_GLOBAL_LOCK

See Also:

• Constant Field Values

PROP_CONSUMER

public static final String PROP_CONSUMER

See Also:

• Constant Field Values

PROP_CACHE_SIZE

public static final String PROP_CACHE_SIZE

See Also:

• Constant Field Values

PROP_CACHE_SIZE_BYTES_KB

public static final String PROP_CACHE_SIZE_BYTES_KB

See Also:

• Constant Field Values

PREFIX_TEMP_QUEUE

public static final String PREFIX_TEMP_QUEUE

See Also:

• Constant Field Values

SYSTEM_QUEUE_CHAR

public static final char SYSTEM_QUEUE_CHAR

See Also:

• Constant Field Values

Constructor Details

QueueManagerImpl

public QueueManagerImpl()

Method Details

createSwiftletContext

protected SwiftletContext createSwiftletContext(com.swiftmq.mgmt.Configuration config)

createMessaageGroupDispatchPolicyFactory

public MessageGroupDispatchPolicyFactory createMessaageGroupDispatchPolicyFactory()

createTempQueueFactory

protected TempQueueFactory createTempQueueFactory()

createSystemQueueFactory

protected SystemQueueFactory createSystemQueueFactory()

createRegularQueueFactory

protected RegularQueueFactory createRegularQueueFactory()

createMessageQueueFactory

protected MessageQueueFactory createMessageQueueFactory()

createCacheTableFactory

protected CacheTableFactory createCacheTableFactory()

getMaxFlowControlDelay

public long getMaxFlowControlDelay()

Specified by:

getMaxFlowControlDelay in class com.swiftmq.swiftlet.queue.QueueManager

isLogDuplicates

public boolean isLogDuplicates()

isLogExpired

public boolean isLogExpired()

isDeliverExpired

public boolean isDeliverExpired()

isTemporaryQueue

public boolean isTemporaryQueue(String queueName)

Specified by:

isTemporaryQueue in class com.swiftmq.swiftlet.queue.QueueManager

isSystemQueue

public boolean isSystemQueue(String queueName)

Specified by:

isSystemQueue in class com.swiftmq.swiftlet.queue.QueueManager

stripLocalName

public String stripLocalName(String name)

getQueueForInternalUse

public com.swiftmq.swiftlet.queue.AbstractQueue getQueueForInternalUse(String queueName)

Specified by:

getQueueForInternalUse in class com.swiftmq.swiftlet.queue.QueueManager

getQueueForInternalUse

public com.swiftmq.swiftlet.queue.AbstractQueue getQueueForInternalUse(String queueName,
 boolean respectRedirection)

fqn

public String fqn(String queueName)

isQueueDefined

public boolean isQueueDefined(String queueName)

Specified by:

isQueueDefined in class com.swiftmq.swiftlet.queue.QueueManager

isQueueRunning

public boolean isQueueRunning(String queueName)

Specified by:

isQueueRunning in class com.swiftmq.swiftlet.queue.QueueManager

createQueueSender

public com.swiftmq.swiftlet.queue.QueueSender createQueueSender(String queueName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
                                                         throws com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.auth.AuthenticationException

Specified by:

createQueueSender in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.auth.AuthenticationException

createQueueReceiver

public com.swiftmq.swiftlet.queue.QueueReceiver createQueueReceiver(String queueName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin,
 com.swiftmq.swiftlet.queue.Selector selector)
                                                             throws com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.auth.AuthenticationException

Specified by:

createQueueReceiver in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.auth.AuthenticationException

createQueueBrowser

public com.swiftmq.swiftlet.queue.QueueBrowser createQueueBrowser(String queueName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin,
 com.swiftmq.swiftlet.queue.Selector selector)
                                                           throws com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.auth.AuthenticationException

Specified by:

createQueueBrowser in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.auth.AuthenticationException

addQueueManagerListener

public void addQueueManagerListener(com.swiftmq.swiftlet.queue.event.QueueManagerListener l)

Specified by:

addQueueManagerListener in class com.swiftmq.swiftlet.queue.QueueManager

addQueueManagerListener

public void addQueueManagerListener(String queueName,
 com.swiftmq.swiftlet.queue.event.QueueManagerListener l)
                             throws com.swiftmq.swiftlet.queue.UnknownQueueException

Specified by:

addQueueManagerListener in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.UnknownQueueException

removeQueueManagerListener

public void removeQueueManagerListener(com.swiftmq.swiftlet.queue.event.QueueManagerListener l)

Specified by:

removeQueueManagerListener in class com.swiftmq.swiftlet.queue.QueueManager

removeQueueManagerListener

public void removeQueueManagerListener(String queueName,
 com.swiftmq.swiftlet.queue.event.QueueManagerListener l)

Specified by:

removeQueueManagerListener in class com.swiftmq.swiftlet.queue.QueueManager

performTimeAction

public void performTimeAction()

Specified by:

performTimeAction in interface com.swiftmq.swiftlet.timer.event.TimerListener

createQueue

public void createQueue(String queueName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
                 throws com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.auth.AuthenticationException

Specified by:

createQueue in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.auth.AuthenticationException

createQueue

public void createQueue(String queueName,
 com.swiftmq.swiftlet.queue.QueueFactory factory)
                 throws com.swiftmq.swiftlet.queue.QueueException

Specified by:

createQueue in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

deleteQueue

public void deleteQueue(String queueName,
 boolean onEmpty)
                 throws com.swiftmq.swiftlet.queue.QueueException

Specified by:

deleteQueue in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

createTemporaryQueue

public String createTemporaryQueue()
                            throws com.swiftmq.swiftlet.queue.QueueException

Specified by:

createTemporaryQueue in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

deleteTemporaryQueue

public void deleteTemporaryQueue(String queueName)
                          throws com.swiftmq.swiftlet.queue.QueueException

Specified by:

deleteTemporaryQueue in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

purgeQueue

public void purgeQueue(String queueName)
                throws com.swiftmq.swiftlet.queue.QueueException

Specified by:

purgeQueue in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.QueueException

getDefinedQueueNames

public String[] getDefinedQueueNames()

Specified by:

getDefinedQueueNames in class com.swiftmq.swiftlet.queue.QueueManager

setQueueOutboundRedirector

public void setQueueOutboundRedirector(String likePredicate,
 String outboundQueueName)
                                throws com.swiftmq.swiftlet.queue.UnknownQueueException

Specified by:

setQueueOutboundRedirector in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.UnknownQueueException

setQueueInboundRedirector

public void setQueueInboundRedirector(String likePredicate,
 String inboundQueueName)
                               throws com.swiftmq.swiftlet.queue.UnknownQueueException

Specified by:

setQueueInboundRedirector in class com.swiftmq.swiftlet.queue.QueueManager

Throws:

com.swiftmq.swiftlet.queue.UnknownQueueException

startCluster

protected void startCluster()
                     throws Exception

Throws:

Exception

startup

protected void startup(com.swiftmq.mgmt.Configuration config)
                throws com.swiftmq.swiftlet.SwiftletException

Specified by:

startup in class com.swiftmq.swiftlet.Swiftlet

Throws:

com.swiftmq.swiftlet.SwiftletException

shutdown

protected void shutdown()
                 throws com.swiftmq.swiftlet.SwiftletException

Specified by:

shutdown in class com.swiftmq.swiftlet.Swiftlet

Throws:

com.swiftmq.swiftlet.SwiftletException