osmq.broker.subqueues
Class SubscriberQueue
java.lang.Object
osmq.mque.MQue
osmq.mque.PersistableMQue
osmq.broker.subqueues.SubscriberQueue
- All Implemented Interfaces:
- EventCounter, java.io.Serializable, Writable
- public class SubscriberQueue
- extends PersistableMQue
- implements java.io.Serializable
A Message queue created for a named subscriber. The Queue
also contains a Vector of topics that are associated with this
subscriber.
- See Also:
- Serialized Form
Methods inherited from class osmq.mque.MQue |
clear, clearHighestSize, close, flushToPullCount, getBytesWritten, getEventCount, getInstanceName, getMaxThreshold, getPagingThreshold, getPullCount, getPushCount, highestSize, isClosed, isEmpty, isHaltReads, isHaltWrites, isOpen, nextElement, open, putBack, readBytes, readBytesNoWait, readString, readStringNoWait, setHaltWrites, setInstanceName, setMaxThreshold, setPagingThreshold, size, toString, writeAllFromQue, writeBytes, writeBytesNoDuplicate, writeString |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
QUEUE_THRESHOLD
public static int QUEUE_THRESHOLD
SubscriberQueue
public SubscriberQueue(java.lang.String recipient)
isAttached
public boolean isAttached()
setIpAddress
public void setIpAddress(java.lang.String ipaddress)
getIpAddress
public java.lang.String getIpAddress()
inshutdown
public static boolean inshutdown()
setInShutdown
public static void setInShutdown()
addATopic
public void addATopic(java.lang.String topic)
removeATopic
public void removeATopic(java.lang.String topic)
hasTopics
public boolean hasTopics()
getSaveFileName
public java.lang.String getSaveFileName()
- Overrides:
getSaveFileName
in class PersistableMQue
getFirstTopic
public final java.lang.String getFirstTopic()