com.retrogui.messageserver.common
Class InboundMessageHandler

java.lang.Object
  extended byjava.lang.Thread
      extended bycom.retrogui.messageserver.common.InboundMessageHandler
All Implemented Interfaces:
java.lang.Runnable

public class InboundMessageHandler
extends java.lang.Thread

incoming messages are placed into an inbound queue


Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
InboundMessageHandler(Session session)
          Constructor
 
Method Summary
protected  java.io.BufferedReader getInstream()
          getter
 Message getMessage(boolean blockUntilMessage)
          get a message from the inbound queue.
 IMessageEncoder getMessageEncoder()
           
protected  java.lang.Object getMessageMonitor()
          getter
 IMessageSerializer getMessageSerializer()
           
protected  ThreadsafeQueue getQueue()
          getter
protected  Session getSession()
          getter
protected  boolean isSignalToStop()
          getter
 void run()
          run loop
protected  void setInstream(java.io.BufferedReader instream)
          setter
 void setMessageEncoder(IMessageEncoder messageEncoder)
           
protected  void setMessageMonitor(java.lang.Object messageLock)
          setter
 void setMessageSerializer(IMessageSerializer messageSerializer)
           
protected  void setQueue(ThreadsafeQueue queue)
          setter
protected  void setSession(Session session)
          setter
 void setSignalToStop(boolean signalToStop)
          usually called by session.closeSession() to signal that this thread must terminate.
 
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
 

Constructor Detail

InboundMessageHandler

public InboundMessageHandler(Session session)
Constructor

Parameters:
session -
See Also:
Method Detail

setSignalToStop

public void setSignalToStop(boolean signalToStop)
usually called by session.closeSession() to signal that this thread must terminate. Sets the signalToStop flag true and notifies waiting thread synchronized for communication

Parameters:
signalToStop -
See Also:

getMessage

public Message getMessage(boolean blockUntilMessage)
                   throws SessionException
get a message from the inbound queue. blocking and non-blocking modes.

Parameters:
blockUntilMessage -
Returns:
Throws:
SessionException
See Also:

run

public void run()
run loop

See Also:

setSession

protected void setSession(Session session)
setter

Parameters:
session -

getSession

protected Session getSession()
getter

Returns:

setQueue

protected void setQueue(ThreadsafeQueue queue)
setter

Parameters:
queue -

getQueue

protected ThreadsafeQueue getQueue()
getter

Returns:

setInstream

protected void setInstream(java.io.BufferedReader instream)
setter

Parameters:
instream -

getInstream

protected java.io.BufferedReader getInstream()
getter

Returns:

isSignalToStop

protected boolean isSignalToStop()
getter

Returns:

setMessageMonitor

protected void setMessageMonitor(java.lang.Object messageLock)
setter

Parameters:
messageLock -

getMessageMonitor

protected java.lang.Object getMessageMonitor()
getter

Returns:

setMessageSerializer

public void setMessageSerializer(IMessageSerializer messageSerializer)
Parameters:
messageSerializer - The messageSerializer to set.

getMessageSerializer

public IMessageSerializer getMessageSerializer()
Returns:
Returns the messageSerializer.

setMessageEncoder

public void setMessageEncoder(IMessageEncoder messageEncoder)
Parameters:
messageEncoder - The messageEncoder to set.

getMessageEncoder

public IMessageEncoder getMessageEncoder()
Returns:
Returns the messageEncoder.