communication
Class CommunicationElement.Receiver

java.lang.Object
  java.lang.Thread
      communication.CommunicationElement.Receiver

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

CommunicationElement

protected class CommunicationElement.Receiver
extends java.lang.Thread

Thread that loops indefinitely for receiving messages through the TCP element associated with the communication element

Nested Class Summary

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

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

Field Summary

protected SynchronizedBuffer	msgBuffer Message buffer in which received messages are placed
protected TCPElement	tcp TCP element managing the socket for receiving messages

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

CommunicationElement.Receiver(SynchronizedBuffer msgBuffer, TCPElement tcp)

Method Summary

void

run()

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

msgBuffer

protected SynchronizedBuffer msgBuffer

Message buffer in which received messages are placed

tcp

protected TCPElement tcp

TCP element managing the socket for receiving messages

Constructor Detail

CommunicationElement.Receiver

public CommunicationElement.Receiver(SynchronizedBuffer msgBuffer,
                                     TCPElement tcp)

Parameters:

msgBuffer -

tcp -

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread