when:
        initializer.onQueueAdded(queue)

        then:
        0 * queue._
    }

    def "discards message on end of stream received"() {
        given:
        def closed = new EndOfStream()

        initializer.onStatefulMessage(closed)

        when:
        initializer.onQueueAdded(queue)

        then:
        1 * queue.dispatch(closed)
        0 * queue._
    }

            return;
        }
        final Deque<Object> queue = new ArrayDeque<Object>(mutableValues.size() + immutableValues.size());
        queue.addAll(immutableValues);
        queue.addAll(mutableValues);
        while (!queue.isEmpty()) {
            Object dependency = queue.removeFirst();
            if (dependency instanceof Buildable) {
                context.add(dependency);

 *
 */
public interface UrlQueueService<QUEUE extends UrlQueue<?>> {

    void updateSessionId(String oldSessionId, String newSessionId);

    void add(String sessionId, String url);

    void insert(QUEUE urlQueue);

    void delete(String sessionId);

    void deleteAll();

    void offerAll(String sessionId, List<QUEUE> newUrlQueueList);

    QUEUE poll(String sessionId);

  /**
   * Constructs a new finalizable soft reference.
   *
   * @param referent to softly reference
   * @param queue that should finalize the referent
   */
  protected FinalizableSoftReference(@CheckForNull T referent, FinalizableReferenceQueue queue) {
    super(referent, queue.queue);
    queue.cleanUp();
  }

  /**
   * Constructs a new finalizable soft reference.
   *
   * @param referent to softly reference
   * @param queue that should finalize the referent
   */
  protected FinalizableSoftReference(@CheckForNull T referent, FinalizableReferenceQueue queue) {
    super(referent, queue.queue);
    queue.cleanUp();
  }

        1 * buildOperationExecutor.runAll(commandLineTool, _) >> { worker, action -> action.execute(queue) }
        1 * invocationContext.getArgAction() >> Actions.doNothing()
        1 * invocationContext.createInvocation("linking lib", expectedArgs, operationLogger) >> invocation
        1 * queue.add(invocation)
        1 * queue.setLogLocation(LOG_LOCATION)
        0 * _
    }

    List<String> getSoNameProp(def value) {

                instant.worker2Ready
                ConcurrentSpec spec = this;
                def child2 = workerLeaseService.startWorker()
                processor.runAll(processorWorker, { queue ->
                    queue.add(new DefaultBuildOperationQueueTest.TestBuildOperation() {
                        @Override
                        void run(BuildOperationContext buildOperationContext) {

/**
 * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders
 * elements FIFO (first-in-first-out). The head of the queue is that element that has been
 * on the queue the longest time. The tail of the queue is that element that has been on
 * the queue the shortest time. New elements are inserted at the tail of the queue, and the queue
 * retrieval operations obtain elements at the head of the queue.

        Set<Class<?>> seenInterfaces = new HashSet<>();
        Queue<Class<? super T>> queue = new ArrayDeque<Class<? super T>>();
        queue.add(clazz);
        Class<? super T> type;
        while ((type = queue.poll()) != null) {
            if (excludedTypes.contains(type)) {
                continue;
            }

    }

    @Override
    public void run(RunNotifier notifier) {
        LinkedList<Description> queue = new LinkedList<Description>();
        queue.add(runner.getDescription());
        while (!queue.isEmpty()) {
            Description description = queue.removeFirst();
            queue.addAll(description.getChildren());
            if (description.isTest()) {
                notifier.fireTestIgnored(description);