Running Quarkus test with reactive messaging and get java.lang.IllegalStateException: No CDI container is available

[joe-specimen]

I am trying to learn quarkus-messaging-amqp and that is why I created a very simple project where I have one consumer which has @Incoming("executor-in") annotation where I log what was consumed (Executor object). I also created MessageConverter where I convert from Json string to object (Executor). Now when I send serialized Executor object inside my Junit 5 test I get java.lang.IllegalStateException: No CDI container is available which I do not know why. This happens if I run the test inside Intellij.
NOTE
One important thing is that the test is working but method for message consuming is not being called.

The funny thing is that if I do not convert Json to Executor (inside MessageConverter class) object and just resend Message<?> with Json payload and change method argument from Executor to String then everything works.

To not pollute the space too much with the code I also attach link to project on GitHub: link

Thanks for any help in advance.

[quarkus-bot[bot]]

/cc @Ladicek (arc), @cescoffier (reactive-messaging), @manovotn (arc), @mkouba (arc), @ozangunalp (reactive-messaging)

[Ladicek]

This is because your test sends the message and immediately stops; it doesn't wait for the processing to finish. When Quarkus stops, an exception like this can happen very easily (as well as a bunch of other exceptions). If you for example add Thread.sleep(5000) to the end of the @Test method, the exception isn't thrown.

[joe-specimen]

@Ladicek Firstly, thanks for your answer. The answer you provided is very interesting 👍. I have created my test according to the QuoteProcessorTest inside of quarkus-quickstarts and edited a bit for my needs. There this code works, why is that? And also if I just resend Message with Json paylod and of course change the onMessage signature accordingly it works. Is there any explanation for this.
Is there any other way how to send the message and wait for the message to be consumed. Are there any examples how to do this correctly because I do not wan't to use Thread.sleep(5000) because this looks more like a hack for solving the problem which lies somewhere else.

[Ladicek]

Looking at the QuoteProcessorTest, it waits for the message to be delivered to the queue, which is what you could also do.

[joe-specimen]

@Ladicek But isn't it like that, that only one consumer receives the message?

[joe-specimen]

@Ladicek But isn't it like that, that only one consumer receives the message?

I think that waiting for the message inside of QuoteProcessorTest does only observe (browses) if the message has arrived and it does not acknowledge the message ,so that is why also the onMessage method gets the message to be consumed (and it does the acknowledgement). If I am wrong please correct me.

[joe-specimen]

@Ladicek Sorry for my late response, but I had a lot of other things to do. Yes, you are totally right. I have tried with your proposal of Thread.sleep(5000) and also with waiting for the message to be delivered, and it both works. Thanks for your quick reply 👍. I will also post this answer on the StackOverflow site (here) where I created the initial question.