Package com.swiftmq.impl.topic.standard

Class TopicSubscription

java.lang.Object

com.swiftmq.impl.topic.standard.TopicSubscription

public class TopicSubscription
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TopicSubscription(int subscriberId, String topicName, String[] tokenizedName, boolean noLocal, Selector selector, ActiveLogin activeLogin, String subscriberQueueName)
protected	TopicSubscription(TopicInfo topicInfo, TopicBroker broker)

Method Summary

Modifier and Type	Method	Description
protected TopicSubscriberTransaction	createTransaction()
boolean	equals(Object o)
ActiveLogin	getActiveLogin()
TopicBroker	getBroker()
int	getBrokerSubscriberId()
String	getDestination()
int	getNumberSubscriberQueueMessages()
Selector	getSelector()
int	getSubscriberId()
String	getSubscriberQueueName()
String[]	getTokenizedName()
String	getTopicName()
boolean	isAnnounced()
boolean	isDurable()
boolean	isForceCopy()
boolean	isKeepOnUnsubscribe()
boolean	isNoLocal()
boolean	isRemote()
boolean	isRemovePending()
boolean	isStaticSubscription()
protected void	removeTransaction(TopicSubscriberTransaction transaction)
void	setAnnounced(boolean announced)
void	setBroker(TopicBroker broker)
void	setBrokerSubscriberId(int brokerSubscriberId)
void	setDurable(boolean durable)
void	setForceCopy(boolean forceCopy)
void	setKeepOnUnsubscribe(boolean keepOnUnsubscribe)
void	setRemovePending(boolean removePending)
void	setStaticSubscription(boolean staticSubscription)
void	setSubscriberId(int subscriberId)
String	toString()
protected void	unsubscribe()

Methods inherited from class java.lang.Object

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

Constructor Details

TopicSubscription

protected TopicSubscription(int subscriberId,
 String topicName,
 String[] tokenizedName,
 boolean noLocal,
 Selector selector,
 ActiveLogin activeLogin,
 String subscriberQueueName)

TopicSubscription

protected TopicSubscription(TopicInfo topicInfo,
 TopicBroker broker)

Method Details

isForceCopy

public boolean isForceCopy()

setForceCopy

public void setForceCopy(boolean forceCopy)

isDurable

public boolean isDurable()

setDurable

public void setDurable(boolean durable)

isStaticSubscription

public boolean isStaticSubscription()

setStaticSubscription

public void setStaticSubscription(boolean staticSubscription)

setKeepOnUnsubscribe

public void setKeepOnUnsubscribe(boolean keepOnUnsubscribe)

isKeepOnUnsubscribe

public boolean isKeepOnUnsubscribe()

isAnnounced

public boolean isAnnounced()

setAnnounced

public void setAnnounced(boolean announced)

isRemote

public boolean isRemote()

setSubscriberId

public void setSubscriberId(int subscriberId)

getSubscriberId

public int getSubscriberId()

setBrokerSubscriberId

public void setBrokerSubscriberId(int brokerSubscriberId)

getBrokerSubscriberId

public int getBrokerSubscriberId()

setBroker

public void setBroker(TopicBroker broker)

getBroker

public TopicBroker getBroker()

getTopicName

public String getTopicName()

getTokenizedName

public String[] getTokenizedName()

getSelector

public Selector getSelector()

isNoLocal

public boolean isNoLocal()

getActiveLogin

public ActiveLogin getActiveLogin()

getDestination

public String getDestination()

getSubscriberQueueName

public String getSubscriberQueueName()

getNumberSubscriberQueueMessages

public int getNumberSubscriberQueueMessages()
                                     throws Exception

Throws:

Exception

isRemovePending

public boolean isRemovePending()

setRemovePending

public void setRemovePending(boolean removePending)

createTransaction

protected TopicSubscriberTransaction createTransaction()
                                                throws Exception

Throws:

Exception

removeTransaction

protected void removeTransaction(TopicSubscriberTransaction transaction)

unsubscribe

protected void unsubscribe()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object