org.apache.http.impl.nio.reactor
Class BaseIOReactor

java.lang.Object
  extended by org.apache.http.impl.nio.reactor.AbstractIOReactor
      extended by org.apache.http.impl.nio.reactor.BaseIOReactor
All Implemented Interfaces:
IOReactor

public class BaseIOReactor
extends AbstractIOReactor


Constructor Summary
BaseIOReactor(long selectTimeout)
           
 
Method Summary
protected  void acceptable(java.nio.channels.SelectionKey key)
           
protected  void connectable(java.nio.channels.SelectionKey key)
           
 void execute(IOEventDispatch eventDispatch)
           
protected  void handleRuntimeException(java.lang.RuntimeException ex)
           
protected  IOSession keyCancelled(java.nio.channels.SelectionKey key)
           
protected  void keyCreated(java.nio.channels.SelectionKey key, IOSession session)
           
protected  void readable(java.nio.channels.SelectionKey key)
           
protected  void sessionClosed(IOSession session)
           
 void setExceptionHandler(IOReactorExceptionHandler exceptionHandler)
           
protected  void timeoutCheck(java.nio.channels.SelectionKey key, long now)
           
protected  void validate(java.util.Set<java.nio.channels.SelectionKey> keys)
           
protected  void writable(java.nio.channels.SelectionKey key)
           
 
Methods inherited from class org.apache.http.impl.nio.reactor.AbstractIOReactor
addChannel, awaitShutdown, closeActiveChannels, closeNewChannels, closeSessions, execute, getStatus, gracefulShutdown, hardShutdown, processEvent, shutdown, shutdown
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BaseIOReactor

public BaseIOReactor(long selectTimeout)
              throws IOReactorException
Throws:
IOReactorException
Method Detail

execute

public void execute(IOEventDispatch eventDispatch)
             throws java.io.InterruptedIOException,
                    IOReactorException
Throws:
java.io.InterruptedIOException
IOReactorException

setExceptionHandler

public void setExceptionHandler(IOReactorExceptionHandler exceptionHandler)

handleRuntimeException

protected void handleRuntimeException(java.lang.RuntimeException ex)

acceptable

protected void acceptable(java.nio.channels.SelectionKey key)
Specified by:
acceptable in class AbstractIOReactor

connectable

protected void connectable(java.nio.channels.SelectionKey key)
Specified by:
connectable in class AbstractIOReactor

readable

protected void readable(java.nio.channels.SelectionKey key)
Specified by:
readable in class AbstractIOReactor

writable

protected void writable(java.nio.channels.SelectionKey key)
Specified by:
writable in class AbstractIOReactor

validate

protected void validate(java.util.Set<java.nio.channels.SelectionKey> keys)
Specified by:
validate in class AbstractIOReactor

timeoutCheck

protected void timeoutCheck(java.nio.channels.SelectionKey key,
                            long now)
Specified by:
timeoutCheck in class AbstractIOReactor

keyCreated

protected void keyCreated(java.nio.channels.SelectionKey key,
                          IOSession session)
Specified by:
keyCreated in class AbstractIOReactor

keyCancelled

protected IOSession keyCancelled(java.nio.channels.SelectionKey key)
Specified by:
keyCancelled in class AbstractIOReactor

sessionClosed

protected void sessionClosed(IOSession session)
Specified by:
sessionClosed in class AbstractIOReactor


Copyright © 2005-2008 Apache Software Foundation. All Rights Reserved.