import java.util.Map;
import java.util.concurrent.locks.Lock;

public class MultiChannelQueue {
    private final Lock lock;
    private final Map<ChannelIdentifier, MultiEndPointQueue> channels = new HashMap<ChannelIdentifier, MultiEndPointQueue>();
    private final QueueInitializer initializer = new QueueInitializer();

    public MultiChannelQueue(Lock lock) {
        this.lock = lock;
    }

package org.gradle.internal.remote.internal.hub;

import org.gradle.internal.remote.internal.hub.protocol.EndOfStream;
import org.gradle.internal.remote.internal.hub.queue.MultiChannelQueue;

import java.util.concurrent.locks.Lock;

class IncomingQueue extends MultiChannelQueue {
    IncomingQueue(Lock lock) {
        super(lock);
    }

    public void requestStop() {
        queue(new EndOfStream());
    }

import org.gradle.internal.remote.internal.hub.protocol.ChannelMessage
import org.gradle.internal.remote.internal.hub.protocol.EndOfStream

class MultiChannelQueueTest extends AbstractQueueTest {
    final MultiChannelQueue queue = new MultiChannelQueue(lock)

    def "adds and caches channel queue on first lookup"() {
        def id1 = new ChannelIdentifier("channel1")
        def id2 = new ChannelIdentifier("channel2")

        expect:

import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.locks.Lock;

// TODO - use circular buffers to avoid copying
// TODO - share a single initializer with MultiChannelQueue
public class MultiEndPointQueue implements Dispatch<InterHubMessage> {
    private final Set<EndPointQueue> endpoints = new HashSet<EndPointQueue>();

Class <org.gradle.internal.remote.internal.hub.queue.MultiChannelQueue> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (MultiChannelQueue.java:0)