org.siebengeisslein.net
Class MessageDispatcher

java.lang.Object
  org.siebengeisslein.util.HasLog
      org.siebengeisslein.net.MessageDispatcher

public class MessageDispatcher
extends HasLog

Constructor Summary

MessageDispatcher(int threadCount, int commitThreadCount, int maxMsgSize)

Method Summary

void	close()
void	dispatch(ConnectionState connectionState)

Methods inherited from class org.siebengeisslein.util.HasLog

getLog

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageDispatcher

public MessageDispatcher(int threadCount,
                         int commitThreadCount,
                         int maxMsgSize)
                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

Method Detail

dispatch

public void dispatch(ConnectionState connectionState)

close

public void close()
           throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException