Package com.swiftmq.impl.topic.standard

Class TopicManagerImpl

java.lang.Object

TopicManager

com.swiftmq.impl.topic.standard.TopicManagerImpl

public class TopicManagerImpl
extends TopicManager

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

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)
AbstractQueue	createQueue(String queueName, Entity queueEntity)
void	createTopic(String topicName)
void	deleteDurable(String durableName, ActiveLogin activeLogin)
void	deleteTopic(String topicName)
String	getDurableTopicName(String durableName, 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(Configuration config)
int	subscribe(TopicImpl topic, Selector selector, boolean noLocal, String queueName, ActiveLogin activeLogin)
int	subscribe(TopicImpl topic, Selector selector, boolean noLocal, String queueName, ActiveLogin activeLogin, boolean forceCopy)
String	subscribeDurable(String durableName, TopicImpl topic, Selector selector, boolean noLocal, ActiveLogin activeLogin)
String	subscribeDurable(String durableName, TopicImpl topic, Selector selector, boolean noLocal, ActiveLogin activeLogin, Entity newEntity)
void	unsubscribe(int subscriberId)
TopicImpl	verifyTopic(TopicImpl topic)

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

getTopicDelimiter

protected String getTopicDelimiter()

isDirectSubscriberSelection

public boolean isDirectSubscriberSelection()

registerUsage

public boolean registerUsage()

createQueue

public AbstractQueue createQueue(String queueName,
 Entity queueEntity)
                          throws QueueException

Throws:

QueueException

createTopic

public void createTopic(String topicName)
                 throws TopicException

Throws:

TopicException

deleteTopic

public void deleteTopic(String topicName)
                 throws TopicException

Throws:

TopicException

isTopicDefined

public boolean isTopicDefined(String topicName)

verifyTopic

public TopicImpl verifyTopic(TopicImpl topic)
                      throws JMSException,
InvalidDestinationException

Throws:

JMSException

InvalidDestinationException

concatName

protected static String concatName(String[] tokenizedName)

subscribe

public int subscribe(TopicImpl topic,
 Selector selector,
 boolean noLocal,
 String queueName,
 ActiveLogin activeLogin)
              throws AuthenticationException

Throws:

AuthenticationException

subscribe

public int subscribe(TopicImpl topic,
 Selector selector,
 boolean noLocal,
 String queueName,
 ActiveLogin activeLogin,
 boolean forceCopy)
              throws AuthenticationException

Throws:

AuthenticationException

subscribeDurable

public String subscribeDurable(String durableName,
 TopicImpl topic,
 Selector selector,
 boolean noLocal,
 ActiveLogin activeLogin)
                        throws AuthenticationException,
QueueException,
TopicException

Throws:

AuthenticationException

QueueException

TopicException

subscribeDurable

public String subscribeDurable(String durableName,
 TopicImpl topic,
 Selector selector,
 boolean noLocal,
 ActiveLogin activeLogin,
 Entity newEntity)
                        throws AuthenticationException,
QueueException,
TopicException

Throws:

AuthenticationException

QueueException

TopicException

deleteDurable

public void deleteDurable(String durableName,
 ActiveLogin activeLogin)
                   throws InvalidDestinationException,
QueueException,
UnknownQueueException,
TopicException

Throws:

InvalidDestinationException

QueueException

UnknownQueueException

TopicException

getDurableTopicName

public String getDurableTopicName(String durableName,
 ActiveLogin activeLogin)

unsubscribe

public void unsubscribe(int subscriberId)

getTopicNames

public String[] getTopicNames()

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(Configuration config)
                throws SwiftletException

Throws:

SwiftletException

shutdown

protected void shutdown()
                 throws SwiftletException

Throws:

SwiftletException