OSMQ
v2.0.1

osmq.broker.subqueues
Class SubscriberQueue

java.lang.Object
  extended byosmq.mque.MQue
      extended byosmq.mque.PersistableMQue
          extended byosmq.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

Field Summary
static int QUEUE_THRESHOLD
           
 
Constructor Summary
SubscriberQueue(java.lang.String recipient)
           
 
Method Summary
 void addATopic(java.lang.String topic)
           
 java.lang.String getFirstTopic()
           
 java.lang.String getIpAddress()
           
 java.lang.String getSaveFileName()
           
 boolean hasTopics()
           
static boolean inshutdown()
           
 boolean isAttached()
           
 void removeATopic(java.lang.String topic)
           
static void setInShutdown()
           
 void setIpAddress(java.lang.String ipaddress)
           
 
Methods inherited from class osmq.mque.PersistableMQue
loadFromLocalFile, loadFromLocalFile, saveAsLocalFile
 
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
 

Field Detail

QUEUE_THRESHOLD

public static int QUEUE_THRESHOLD
Constructor Detail

SubscriberQueue

public SubscriberQueue(java.lang.String recipient)
Method Detail

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()

(c) 2000 - 2003 MQue Systems
All Rights Reserved