com.web_visage.ichatserv.fwk
Class InputDispatcher

java.lang.Object
  com.web_visage.ichatserv.fwk.InputDispatcher

All Implemented Interfaces:

java.lang.Runnable

public class InputDispatcher
extends java.lang.Object
implements java.lang.Runnable

Reads messages from the queue and dispathes them among worker threads.

Author:

K.Baturytski

Constructor Summary

InputDispatcher(java.util.Queue<ServerIChatMessage> aMessageQueue, MessageHandler aMessageHandler, java.util.concurrent.ExecutorService aThreadPool)
Constructor.

Method Summary

void

run()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InputDispatcher

public InputDispatcher(java.util.Queue<ServerIChatMessage> aMessageQueue,
                       MessageHandler aMessageHandler,
                       java.util.concurrent.ExecutorService aThreadPool)

Constructor.

Parameters:

aMessageQueue -

aMessageHandler -

aThreadPool -

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

See Also:

Runnable.run()