import org.gradle.internal.dispatch.Dispatch;
import org.gradle.internal.remote.internal.hub.protocol.EndOfStream;
import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage;

public class QueueInitializer {
    private EndOfStream endOfStream;

    void onStatefulMessage(InterHubMessage message) {
        if (message instanceof EndOfStream) {
            endOfStream = (EndOfStream) message;
        } else {

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;
    }

    public MultiEndPointQueue getChannel(ChannelIdentifier channel) {

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

class QueueInitializerTest extends AbstractQueueTest {
    final QueueInitializer initializer = new QueueInitializer()
    final Dispatch<InterHubMessage> queue = Mock()

    def "does nothing when no stateful messages received"() {
        when:
        initializer.onQueueAdded(queue)

        then:

    private final Deque<InterHubMessage> queue = new ArrayDeque<InterHubMessage>();
    private final List<EndPointQueue> waiting = new ArrayList<EndPointQueue>();
    private final Lock lock;
    private final QueueInitializer initializer = new QueueInitializer();

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

    @Override
    public void dispatch(InterHubMessage message) {
        queue.add(message);

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