org.edg.info
Class QueueManager

java.lang.Object
  extended byorg.edg.info.QueueManager

public class QueueManager
extends java.lang.Object

Contains a queue that holds tuples the Consumer has obtained from its Producers. If the queue becomes full, a disk cache is used to store tuples. At this stage, m_useDiskCache is set to true and no more tuples are inserted into the memory queue until both the queue and disk cache are empty. Then m_useDiskCache is set to false.


Method Summary
 void addResultSets(java.lang.StringBuffer resultSetString)
          Pushes ResultSet objects in resultSets string onto this QueueManager.
 void close()
          Closes this QueueManager and its disk cache.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

close

public void close()
Closes this QueueManager and its disk cache.


addResultSets

public void addResultSets(java.lang.StringBuffer resultSetString)
                   throws QueueManagerException
Pushes ResultSet objects in resultSets string onto this QueueManager.

Parameters:
resultSetString - StringBuffer containing serialized ResultSet objects.
Throws:
QueueManagerException - If the queue is full or can not be written to.