Maciej Jedwabny

Repro: 1. Fill source queue with messages 2. Start consumer 3. Terminate incoming connection using rmq management UI Consumer will try to recover: it manages to restore connection, channel and...

Not sure if this is related but there is also an issue with qos (prefetch count) not getting reapplied after connection failure - consumer buffers all messages. initial state: ...

There is only one place in Microprofile Messaging where `qos` gets set: https://github.com/smallrye/smallrye-reactive-messaging/blob/3d0c49d6ed62824cfda22fc74c3b6816f58ba786/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java#L288 By looking at the underneath rabbitmq-vertx client, there are scenarios where new channel is spawned without applying...

With `max-outstanding-messages=1` it works, "kind of" - consuming is resumed but channel gets recreated every time and redeliveries can be observed:  ``` payload: 93 2023-02-14 16:50:02,271 INFO [io.sma.rea.mes.rabbitmq] (vert.x-worker-thread-0)...

FYI @vietj