given:
        def incoming = incomingQueue.getChannel(channel).newEndpoint()
        outgoingQueue.dispatch(outgoingMessage)

        when:
        connections.noFurtherConnections()
        def messages = []
        incoming.take(messages)

        then:
        messages.size() == 2
        messages[0] instanceof RejectedMessage
        messages[0].payload == "payload"

        if (stopping) {
            maybeStop();
        }
    }

    /**
     * Called when no further incoming connections will be added.
     */
    public void noFurtherConnections() {
        stopping = true;
        maybeStop();
    }

    private void maybeStop() {
        if (connections.isEmpty()) {
            outgoingQueue.discardQueued();

                    methodParamClassLoader,
                    argsSerializer)));

        connection = completion.create(serializer);
        hub.addConnection(connection);
        hub.noFurtherConnections();
        completion = null;
    }

    @Override
    public void requestStop() {
        hub.requestStop();
    }

    @Override
    public void stop() {