Constructor Detail

• AbstractIOSessionPool

  public AbstractIOSessionPool()

Method Detail

• connectSession

  protected abstract Future<IOSession> connectSession(T namedEndpoint,
                                 Timeout connectTimeout,
                                 FutureCallback<IOSession> callback)

• validateSession

  protected abstract void validateSession(IOSession ioSession,
                     Callback<Boolean> callback)

• closeSession

  protected abstract void closeSession(IOSession ioSession,
                  CloseMode closeMode)

• close

  public final void close(CloseMode closeMode)

  Description copied from interface: ModalCloseable
  Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.

  Specified by:

  close in interface ModalCloseable

  Parameters:

  closeMode - How to close the receiver.

• close

  public final void close()

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface AutoCloseable

• getSession

  public final Future<IOSession> getSession(T endpoint,
                             Timeout connectTimeout,
                             FutureCallback<IOSession> callback)

• enumAvailable

  public final void enumAvailable(Callback<IOSession> callback)

• closeIdle

  public final void closeIdle(TimeValue idleTime)

• getRoutes

  public final Set<T> getRoutes()

• toString

  public String toString()

  Overrides:

  toString in class Object