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
The consumers are still pulling new messages from the queue after Kill signal.
On further inspection, what I found was Rabbit Subscribe is using channel.consume() of Amqp rather than Amqp connection manager and hence _consumers is set as empty array.
So when graceful shutdown approach is calling channel.cancelAll(), since _consumers = [], so consumers are not getting cancelled.
The text was updated successfully, but these errors were encountered:
The consumers are still pulling new messages from the queue after Kill signal.
On further inspection, what I found was Rabbit Subscribe is using channel.consume() of Amqp rather than Amqp connection manager and hence _consumers is set as empty array.
So when graceful shutdown approach is calling channel.cancelAll(), since _consumers = [], so consumers are not getting cancelled.
The text was updated successfully, but these errors were encountered: