org.kaariboga.io
Class ReceiveMessageThread

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--org.kaariboga.io.ReceiveMessageThread

All Implemented Interfaces:

java.lang.Runnable

class ReceiveMessageThread

extends java.lang.Thread

Receives a message through a socket connection.

Field Summary

private KbMessageHandler	messageHandler Message handler, that should handle the received message.
private java.util.Collection	receivingThreads Threads, that are currently receiving messages.
private java.net.Socket	socket Socket on which to receive message

Fields inherited from class java.lang.Thread

contextClassLoader, daemon, eetop, group, inheritableThreadLocals, inheritedAccessControlContext, MAX_PRIORITY, MIN_PRIORITY, name, NORM_PRIORITY, priority, single_step, stillborn, stopThreadPermission, target, threadInitNumber, threadLocals, threadQ

Constructor Summary

ReceiveMessageThread(java.net.Socket socket, KbMessageHandler handler, java.util.Collection receivingThreads)
Creates a new Thread to receive a message.

Method Summary

void	run() Reads message.from a socket and dispatches it to the message handler.

Methods inherited from class java.lang.Thread

, activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, exit, getContextClassLoader, getName, getPriority, getThreadGroup, init, interrupt, interrupt0, interrupted, isAlive, isDaemon, isInterrupted, isInterrupted, join, join, join, nextThreadNum, registerNatives, resume, resume0, setContextClassLoader, setDaemon, setName, setPriority, setPriority0, sleep, sleep, start, stop, stop, stop0, suspend, suspend0, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

socket

private java.net.Socket socket

Socket on which to receive message

receivingThreads

private java.util.Collection receivingThreads

Threads, that are currently receiving messages. This class adds and removes itself to the collection, because it knows best when to do it.

messageHandler

private KbMessageHandler messageHandler

Message handler, that should handle the received message.

Constructor Detail

ReceiveMessageThread

public ReceiveMessageThread(java.net.Socket socket,
                            KbMessageHandler handler,
                            java.util.Collection receivingThreads)

Creates a new Thread to receive a message.

Parameters:

socket - Socket of the incoming connection.

handler - KbMessageHander to handle the received message

receivingThreads - List of currently active threads receiving messages.

Method Detail

run

public void run()

Reads message.from a socket and dispatches it to the message handler.

Overrides:

run in class java.lang.Thread