tomcizek / symfony-prooph-asynchronous-router

        );

    }

    public function testInvoke_WithNonRoutedMessage_ShouldThrowRuntimeException()

    {

        $this->givenContainerWithFixtureFiles(

            ['commonServices', 'secondMessageRoute']

        );

        $asynchronousMessageProducer = $this->givenAsynchronousProducerFromContainer(

            'prooph_asynchronous_router.secondProducer'

        );

        $this->expectException(RuntimeException::class);

        $this->whenInvokeMessageProcuderWithFirstMessage($asynchronousMessageProducer);

    }

    public function testInvoke_WithDefferedParam_ShouldThrowRuntimeException()

    {

        $this->whenInvokeMessageProcuderWithFirstMessage($asynchronousMessageProducer);

    }

    public function testInvoke_WithDefferedParam_ShouldThrowRuntimeException()

    {

        $this->givenContainerWithFixtureFiles(

            ['commonServices', 'firstMessageRoute']

        );

        $asynchronousMessageProducer = $this->givenAsynchronousProducerFromContainer(

            'prooph_asynchronous_router.firstProducer'

        );

        $this->expectException(RuntimeException::class);

        $this->whenInvokeMessageProcuderWithDeferredParam($asynchronousMessageProducer);

    }

    protected function givenAsynchronousProducerFromContainer(string $serviceId): AsynchronousMessageProducer

    {