|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectjava.lang.Thread
com.retrogui.messageserver.common.InboundMessageHandler
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 |
public InboundMessageHandler(Session session)
session - | Method Detail |
public void setSignalToStop(boolean signalToStop)
signalToStop -
public Message getMessage(boolean blockUntilMessage)
throws SessionException
blockUntilMessage -
SessionExceptionpublic void run()
protected void setSession(Session session)
session - protected Session getSession()
protected void setQueue(ThreadsafeQueue queue)
queue - protected ThreadsafeQueue getQueue()
protected void setInstream(java.io.BufferedReader instream)
instream - protected java.io.BufferedReader getInstream()
protected boolean isSignalToStop()
protected void setMessageMonitor(java.lang.Object messageLock)
messageLock - protected java.lang.Object getMessageMonitor()
public void setMessageSerializer(IMessageSerializer messageSerializer)
messageSerializer - The messageSerializer to set.public IMessageSerializer getMessageSerializer()
public void setMessageEncoder(IMessageEncoder messageEncoder)
messageEncoder - The messageEncoder to set.public IMessageEncoder getMessageEncoder()
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||