groupmgmt.impl
Class SinglePhaseDisseminator.ProcessMessageQueue

java.lang.Object
  java.lang.Thread
      groupmgmt.impl.SinglePhaseDisseminator.ProcessMessageQueue

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

SinglePhaseDisseminator

private class SinglePhaseDisseminator.ProcessMessageQueue

extends java.lang.Thread

Queue so that we can pause processing of messages during disengagement. Needs to be a separate Thread.

Field Summary

private java.lang.Object	lock
private java.util.Vector	messageQueue
private boolean	running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

private

SinglePhaseDisseminator.ProcessMessageQueue()

Method Summary

void	enqueue(java.lang.Object message)
void	finish()
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

messageQueue

private java.util.Vector messageQueue

running

private boolean running

lock

private java.lang.Object lock

Constructor Detail

SinglePhaseDisseminator.ProcessMessageQueue

private SinglePhaseDisseminator.ProcessMessageQueue()

Method Detail

run

public void run()

enqueue

public void enqueue(java.lang.Object message)

finish

public void finish()