Class TopicManagerImpl

java.lang.Object

com.swiftmq.swiftlet.Swiftlet

com.swiftmq.swiftlet.topic.TopicManager

com.swiftmq.impl.topic.standard.TopicManagerImpl

All Implemented Interfaces:

com.swiftmq.swiftlet.queue.QueueFactory

public class TopicManagerImpl
extends com.swiftmq.swiftlet.topic.TopicManager
implements com.swiftmq.swiftlet.queue.QueueFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DURABLE_DELIMITER
static final String	DURABLE_TYPE
static final String	TOPIC_DELIMITER
static final char	TOPIC_DELIMITER_CHAR
static final String	TOPIC_PREFIX
static final String	TOPIC_QUEUE

Fields inherited from class com.swiftmq.swiftlet.Swiftlet

STATE_ACTIVE, STATE_INACTIVE, STATE_STANDBY

Constructor Summary

Constructors

Constructor	Description
TopicManagerImpl()

Method Summary

Modifier and Type	Method	Description
void	addStaticSubscription(String routerName, String topicName, boolean keepOnUnsubscribe)
protected static String	concatName(String[] tokenizedName)
com.swiftmq.swiftlet.queue.AbstractQueue	createQueue(String queueName, com.swiftmq.mgmt.Entity queueEntity)
void	createTopic(String topicName)
void	deleteDurable(String durableName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
void	deleteTopic(String topicName)
String	getDurableTopicName(String durableName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
protected String	getTopicDelimiter()
String[]	getTopicNames()
protected String	getTopicQueuePrefix()
boolean	isDirectSubscriberSelection()
boolean	isTopicDefined(String topicName)
void	processTopicInfo(TopicInfo topicInfo)
boolean	registerUsage()
void	removeRemoteSubscriptions(String routerName)
protected void	shutdown()
protected void	startup(com.swiftmq.mgmt.Configuration config)
int	subscribe(com.swiftmq.jms.TopicImpl topic, com.swiftmq.swiftlet.queue.Selector selector, boolean noLocal, String queueName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
int	subscribe(com.swiftmq.jms.TopicImpl topic, com.swiftmq.swiftlet.queue.Selector selector, boolean noLocal, String queueName, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin, boolean forceCopy)
String	subscribeDurable(String durableName, com.swiftmq.jms.TopicImpl topic, com.swiftmq.swiftlet.queue.Selector selector, boolean noLocal, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
String	subscribeDurable(String durableName, com.swiftmq.jms.TopicImpl topic, com.swiftmq.swiftlet.queue.Selector selector, boolean noLocal, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin, com.swiftmq.mgmt.Entity newEntity)
void	unsubscribe(int subscriberId)
com.swiftmq.jms.TopicImpl	verifyTopic(com.swiftmq.jms.TopicImpl topic)

Methods inherited from class com.swiftmq.swiftlet.topic.TopicManager

getQueueForTopic, subscribe, subscribe, subscribe, tokenizeTopicName, tokenizeTopicName

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

TOPIC_PREFIX

public static final String TOPIC_PREFIX

See Also:

• Constant Field Values

TOPIC_DELIMITER

public static final String TOPIC_DELIMITER

See Also:

• Constant Field Values

TOPIC_DELIMITER_CHAR

public static final char TOPIC_DELIMITER_CHAR

See Also:

• Constant Field Values

DURABLE_DELIMITER

public static final String DURABLE_DELIMITER

See Also:

• Constant Field Values

DURABLE_TYPE

public static final String DURABLE_TYPE

See Also:

• Constant Field Values

TOPIC_QUEUE

public static final String TOPIC_QUEUE

See Also:

• Constant Field Values

Constructor Details

TopicManagerImpl

public TopicManagerImpl()

Method Details

getTopicQueuePrefix

protected String getTopicQueuePrefix()

Specified by:

getTopicQueuePrefix in class com.swiftmq.swiftlet.topic.TopicManager

getTopicDelimiter

protected String getTopicDelimiter()

Specified by:

getTopicDelimiter in class com.swiftmq.swiftlet.topic.TopicManager

isDirectSubscriberSelection

public boolean isDirectSubscriberSelection()

registerUsage

public boolean registerUsage()

Specified by:

registerUsage in interface com.swiftmq.swiftlet.queue.QueueFactory

createQueue

public com.swiftmq.swiftlet.queue.AbstractQueue createQueue(String queueName,
 com.swiftmq.mgmt.Entity queueEntity)
                                                     throws com.swiftmq.swiftlet.queue.QueueException

Specified by:

createQueue in interface com.swiftmq.swiftlet.queue.QueueFactory

Throws:

com.swiftmq.swiftlet.queue.QueueException

createTopic

public void createTopic(String topicName)
                 throws com.swiftmq.swiftlet.topic.TopicException

Specified by:

createTopic in class com.swiftmq.swiftlet.topic.TopicManager

Throws:

com.swiftmq.swiftlet.topic.TopicException

deleteTopic

public void deleteTopic(String topicName)
                 throws com.swiftmq.swiftlet.topic.TopicException

Specified by:

deleteTopic in class com.swiftmq.swiftlet.topic.TopicManager

Throws:

com.swiftmq.swiftlet.topic.TopicException

isTopicDefined

public boolean isTopicDefined(String topicName)

Specified by:

isTopicDefined in class com.swiftmq.swiftlet.topic.TopicManager

verifyTopic

public com.swiftmq.jms.TopicImpl verifyTopic(com.swiftmq.jms.TopicImpl topic)
                                      throws javax.jms.JMSException,
javax.jms.InvalidDestinationException

Specified by:

verifyTopic in class com.swiftmq.swiftlet.topic.TopicManager

Throws:

javax.jms.JMSException

javax.jms.InvalidDestinationException

concatName

protected static String concatName(String[] tokenizedName)

subscribe

public int subscribe(com.swiftmq.jms.TopicImpl topic,
 com.swiftmq.swiftlet.queue.Selector selector,
 boolean noLocal,
 String queueName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
              throws com.swiftmq.swiftlet.auth.AuthenticationException

Specified by:

subscribe in class com.swiftmq.swiftlet.topic.TopicManager

Throws:

com.swiftmq.swiftlet.auth.AuthenticationException

subscribe

public int subscribe(com.swiftmq.jms.TopicImpl topic,
 com.swiftmq.swiftlet.queue.Selector selector,
 boolean noLocal,
 String queueName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin,
 boolean forceCopy)
              throws com.swiftmq.swiftlet.auth.AuthenticationException

Specified by:

subscribe in class com.swiftmq.swiftlet.topic.TopicManager

Throws:

com.swiftmq.swiftlet.auth.AuthenticationException

subscribeDurable

public String subscribeDurable(String durableName,
 com.swiftmq.jms.TopicImpl topic,
 com.swiftmq.swiftlet.queue.Selector selector,
 boolean noLocal,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
                        throws com.swiftmq.swiftlet.auth.AuthenticationException,
com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.topic.TopicException

Specified by:

subscribeDurable in class com.swiftmq.swiftlet.topic.TopicManager

Throws:

com.swiftmq.swiftlet.auth.AuthenticationException

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.topic.TopicException

subscribeDurable

public String subscribeDurable(String durableName,
 com.swiftmq.jms.TopicImpl topic,
 com.swiftmq.swiftlet.queue.Selector selector,
 boolean noLocal,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin,
 com.swiftmq.mgmt.Entity newEntity)
                        throws com.swiftmq.swiftlet.auth.AuthenticationException,
com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.topic.TopicException

Throws:

com.swiftmq.swiftlet.auth.AuthenticationException

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.topic.TopicException

deleteDurable

public void deleteDurable(String durableName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
                   throws javax.jms.InvalidDestinationException,
com.swiftmq.swiftlet.queue.QueueException,
com.swiftmq.swiftlet.queue.UnknownQueueException,
com.swiftmq.swiftlet.topic.TopicException

Specified by:

deleteDurable in class com.swiftmq.swiftlet.topic.TopicManager

Throws:

javax.jms.InvalidDestinationException

com.swiftmq.swiftlet.queue.QueueException

com.swiftmq.swiftlet.queue.UnknownQueueException

com.swiftmq.swiftlet.topic.TopicException

getDurableTopicName

public String getDurableTopicName(String durableName,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)

Specified by:

getDurableTopicName in class com.swiftmq.swiftlet.topic.TopicManager

unsubscribe

public void unsubscribe(int subscriberId)

Specified by:

unsubscribe in class com.swiftmq.swiftlet.topic.TopicManager

getTopicNames

public String[] getTopicNames()

Specified by:

getTopicNames in class com.swiftmq.swiftlet.topic.TopicManager

removeRemoteSubscriptions

public void removeRemoteSubscriptions(String routerName)

processTopicInfo

public void processTopicInfo(TopicInfo topicInfo)
                      throws Exception

Throws:

Exception

addStaticSubscription

public void addStaticSubscription(String routerName,
 String topicName,
 boolean keepOnUnsubscribe)
                           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