Package com.swiftmq.impl.queue.standard

Class QueueManagerImpl

java.lang.Object

QueueManager

com.swiftmq.impl.queue.standard.QueueManagerImpl

public class QueueManagerImpl
extends QueueManager

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

Constructor Summary

Constructors

Constructor	Description
QueueManagerImpl()

Method Summary

Modifier and Type	Method	Description
void	addQueueManagerListener(String queueName, QueueManagerListener l)
void	addQueueManagerListener(QueueManagerListener l)
protected CacheTableFactory	createCacheTableFactory()
MessageGroupDispatchPolicyFactory	createMessaageGroupDispatchPolicyFactory()
protected MessageQueueFactory	createMessageQueueFactory()
void	createQueue(String queueName, ActiveLogin activeLogin)
void	createQueue(String queueName, QueueFactory factory)
QueueBrowser	createQueueBrowser(String queueName, ActiveLogin activeLogin, Selector selector)
QueueReceiver	createQueueReceiver(String queueName, ActiveLogin activeLogin, Selector selector)
QueueSender	createQueueSender(String queueName, ActiveLogin activeLogin)
protected RegularQueueFactory	createRegularQueueFactory()
protected SwiftletContext	createSwiftletContext(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()
AbstractQueue	getQueueForInternalUse(String queueName)
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(String queueName, QueueManagerListener l)
void	removeQueueManagerListener(QueueManagerListener l)
void	setQueueInboundRedirector(String likePredicate, String inboundQueueName)
void	setQueueOutboundRedirector(String likePredicate, String outboundQueueName)
protected void	shutdown()
protected void	startCluster()
protected void	startup(Configuration config)
String	stripLocalName(String name)

Methods inherited from class java.lang.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(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()

isLogDuplicates

public boolean isLogDuplicates()

isLogExpired

public boolean isLogExpired()

isDeliverExpired

public boolean isDeliverExpired()

isTemporaryQueue

public boolean isTemporaryQueue(String queueName)

isSystemQueue

public boolean isSystemQueue(String queueName)

stripLocalName

public String stripLocalName(String name)

getQueueForInternalUse

public AbstractQueue getQueueForInternalUse(String queueName)

getQueueForInternalUse

public AbstractQueue getQueueForInternalUse(String queueName,
 boolean respectRedirection)

fqn

public String fqn(String queueName)

isQueueDefined

public boolean isQueueDefined(String queueName)

isQueueRunning

public boolean isQueueRunning(String queueName)

createQueueSender

public QueueSender createQueueSender(String queueName,
 ActiveLogin activeLogin)
                              throws QueueException,
AuthenticationException

Throws:

QueueException

AuthenticationException

createQueueReceiver

public QueueReceiver createQueueReceiver(String queueName,
 ActiveLogin activeLogin,
 Selector selector)
                                  throws QueueException,
AuthenticationException

Throws:

QueueException

AuthenticationException

createQueueBrowser

public QueueBrowser createQueueBrowser(String queueName,
 ActiveLogin activeLogin,
 Selector selector)
                                throws QueueException,
AuthenticationException

Throws:

QueueException

AuthenticationException

addQueueManagerListener

public void addQueueManagerListener(QueueManagerListener l)

addQueueManagerListener

public void addQueueManagerListener(String queueName,
 QueueManagerListener l)
                             throws UnknownQueueException

Throws:

UnknownQueueException

removeQueueManagerListener

public void removeQueueManagerListener(QueueManagerListener l)

removeQueueManagerListener

public void removeQueueManagerListener(String queueName,
 QueueManagerListener l)

performTimeAction

public void performTimeAction()

createQueue

public void createQueue(String queueName,
 ActiveLogin activeLogin)
                 throws QueueException,
AuthenticationException

Throws:

QueueException

AuthenticationException

createQueue

public void createQueue(String queueName,
 QueueFactory factory)
                 throws QueueException

Throws:

QueueException

deleteQueue

public void deleteQueue(String queueName,
 boolean onEmpty)
                 throws QueueException

Throws:

QueueException

createTemporaryQueue

public String createTemporaryQueue()
                            throws QueueException

Throws:

QueueException

deleteTemporaryQueue

public void deleteTemporaryQueue(String queueName)
                          throws QueueException

Throws:

QueueException

purgeQueue

public void purgeQueue(String queueName)
                throws QueueException

Throws:

QueueException

getDefinedQueueNames

public String[] getDefinedQueueNames()

setQueueOutboundRedirector

public void setQueueOutboundRedirector(String likePredicate,
 String outboundQueueName)
                                throws UnknownQueueException

Throws:

UnknownQueueException

setQueueInboundRedirector

public void setQueueInboundRedirector(String likePredicate,
 String inboundQueueName)
                               throws UnknownQueueException

Throws:

UnknownQueueException

startCluster

protected void startCluster()
                     throws Exception

Throws:

Exception

startup

protected void startup(Configuration config)
                throws SwiftletException

Throws:

SwiftletException

shutdown

protected void shutdown()
                 throws SwiftletException

Throws:

SwiftletException