infoservice.agreement.multicast
Class MessageHandlerThread

java.lang.Object
  java.lang.Thread
      infoservice.agreement.multicast.MessageHandlerThread

All Implemented Interfaces:

java.lang.Runnable

public class MessageHandlerThread
extends java.lang.Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

private AbstractEMCAdapter	m_agreementHandler
private boolean	m_bRunning
private FifoQueue	m_queue

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

MessageHandlerThread(AbstractEMCAdapter a_handler, FifoQueue a_queue)
LERNGRUPPE Creates a new MessageHandler.

Method Summary

void	run()
void	setRunning(boolean a_bRunning) LERNGRUPPE Sets the m_bRunning member

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, 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

m_bRunning

private boolean m_bRunning

m_agreementHandler

private AbstractEMCAdapter m_agreementHandler

m_queue

private FifoQueue m_queue

Constructor Detail

MessageHandlerThread

public MessageHandlerThread(AbstractEMCAdapter a_handler,
                            FifoQueue a_queue)

LERNGRUPPE Creates a new MessageHandler. When notified it will pop a message off the given queue and call the given handler to handle it.

Parameters:

a_handler - The ArgreementHandler to handle the messages

a_queue - A queue of messages

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

setRunning

public void setRunning(boolean a_bRunning)

LERNGRUPPE Sets the m_bRunning member

Parameters:

a_bRunning - the new value of m_bRunning