class FairCallQueue extends AbstractQueue<E> implements BlockingQueue<E> {

  @Override
  public E poll(long timeout, TimeUnit unit) throws InterruptedException {
    return semaphore.tryAcquire(timeout, unit) ? removeNextElement() : null;
  }

  public  FairCallQueue(int priorityLevels, int capacity, String ns,
      Configuration conf);

}