You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Queues are automatically declared for MQTT consumers. Currently we assume they don't get deleted externally (eg. manually by a user) but technically they can be. The consumer should be disconnected in such case, because it has no way of knowing this happened - from its perspective there are simply no messages to consume.
In RabbitMQ 3.11 the consumer was disconnected in such situations because that's what AMQP does. This behaviour changed with native MQTT, which doesn't use AMQP internally.
Describe the bug
Queues are automatically declared for MQTT consumers. Currently we assume they don't get deleted externally (eg. manually by a user) but technically they can be. The consumer should be disconnected in such case, because it has no way of knowing this happened - from its perspective there are simply no messages to consume.
In RabbitMQ 3.11 the consumer was disconnected in such situations because that's what AMQP does. This behaviour changed with native MQTT, which doesn't use AMQP internally.
Reproduction steps
Expected behavior
When a queue declared for an MQTT consumer is deleted, the consumer should be disconnected.
Additional context
No response
The text was updated successfully, but these errors were encountered: