org.jlab.coda.cMsg.cMsgDomain.client
Class cMsgClientListeningThread

java.lang.Object
  extended by java.lang.Thread
      extended by org.jlab.coda.cMsg.cMsgDomain.client.cMsgClientListeningThread
All Implemented Interfaces:
java.lang.Runnable

public class cMsgClientListeningThread
extends java.lang.Thread

This class implements a cMsg client's thread which listens for communications from the domain server. The server sends it keep alives, messages to which the client has subscribed, and other directives.

Note that the class org.jlab.cMsg.RCDomain.rcListeningThread is largely the same as this one. If there are any changes made here the identical changes should be made there as well.

Version:
1.0
Author:
Carl Timmer

Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
cMsgClientListeningThread(cMsgServerClient myClient, java.nio.channels.ServerSocketChannel channel)
          Constructor for server clients.
cMsgClientListeningThread(cMsg myClient, java.nio.channels.ServerSocketChannel channel)
          Constructor for regular clients.
 
Method Summary
 void killThread()
          Kills this thread.
 void run()
          This method is executed as a thread.
 
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
 

Constructor Detail

cMsgClientListeningThread

public cMsgClientListeningThread(cMsg myClient,
                                 java.nio.channels.ServerSocketChannel channel)
Constructor for regular clients.

Parameters:
myClient - cMsg client that created this object
channel - socket for listening for connections

cMsgClientListeningThread

public cMsgClientListeningThread(cMsgServerClient myClient,
                                 java.nio.channels.ServerSocketChannel channel)
Constructor for server clients.

Parameters:
myClient - cMsg server client that created this object
channel - suggested port on which to starting listening for connections
Method Detail

killThread

public void killThread()
Kills this thread.


run

public void run()
This method is executed as a thread.

Specified by:
run in interface java.lang.Runnable
Overrides:
run in class java.lang.Thread