class Acceptor {

  public Exception getPendingException() {
    synchronized (m_socketSets) {
      if (m_isShutdown) {
        return null;
      }
    }

    try {
      return m_exceptionQueue.take();
    }
    catch (InterruptedException e) {
      throw new UncheckedInterruptedException(e);
    }
  }

  public  Acceptor(String addressString,
                  int port,
                  int numberOfThreads,
                  TimeAuthority timeAuthority);

}