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
It seems like py-amqp only sets the Channel.active flag when receiving flow control messages. Is this accurate?
Does that then mean it's the job of services important and using py-amqp to check this Channel.active flag and do something sensible? It seems like Celery/Kombu don't pay attention to the flag and simply try to keep sending messages when the channel has gone into flow control.
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
It seems like py-amqp only sets the
Channel.active
flag when receiving flow control messages. Is this accurate?Does that then mean it's the job of services important and using py-amqp to check this
Channel.active
flag and do something sensible? It seems like Celery/Kombu don't pay attention to the flag and simply try to keep sending messages when the channel has gone into flow control.Beta Was this translation helpful? Give feedback.
All reactions