org.activeio.filter
Class AsyncWriteAsyncChannel.ObjectDispatcherX

java.lang.Object
  extended byorg.activeio.filter.AsyncWriteAsyncChannel.ObjectDispatcherX
All Implemented Interfaces:
Runnable
Enclosing class:
AsyncWriteAsyncChannel

public static class AsyncWriteAsyncChannel.ObjectDispatcherX
extends Object
implements Runnable


Constructor Summary
AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener)
           
AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener, Executor executor, Channel queue)
           
AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener, int queueSize)
           
 
Method Summary
 void add(Object o)
           
 void run()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AsyncWriteAsyncChannel.ObjectDispatcherX

public AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener)

AsyncWriteAsyncChannel.ObjectDispatcherX

public AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener,
                                                int queueSize)

AsyncWriteAsyncChannel.ObjectDispatcherX

public AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener,
                                                Executor executor,
                                                Channel queue)
Method Detail

add

public void add(Object o)
         throws InterruptedException
Throws:
InterruptedException

run

public void run()
Specified by:
run in interface Runnable


Copyright © -2007 The ActiveIO Project. All Rights Reserved.