shenjiatong 196fa877a9 Cancel consumer if queue down ... Previously, we have switched to use default exchanges to avoid excessive amounts of exchange not found messages. But it does not actually solve the problem because reply_* queue is already gone and agent will not receive callbacks. after some debugging, I found under some circumstances seems rabbitmq consumer does not receive basic cancel signal when queue is already gone. This might due to rabbitmq try to restart consumer when queue is down (for example when split brain). In such cases, it might be better to fail early. by reading the code, seems like x-cancel-on-ha-failover is not dedicated to mirror queues only, https://github.com/rabbitmq/rabbitmq-server/blob/master/src/rabbit_channel.erl#L1894, https://github.com/rabbitmq/rabbitmq-server/blob/master/src/rabbit_channel.erl#L1926. By failing early, in my own test setup, I could solve a certain case of exchange not found problem. Change-Id: I2ae53340783e4044dab58035bc0992dc08145b53 Related-bug: #1789177		2020-07-31 06:05:16 +08:00
..
notify	Setup backend scenarios for functional tests	2020-02-05 08:00:56 -05:00
__init__.py	Move files out of the namespace package	2015-01-12 12:50:41 -05:00
test_functional.py	Remove six usage	2020-05-11 10:21:58 +02:00
test_rabbitmq.py	Cancel consumer if queue down	2020-07-31 06:05:16 +08:00
utils.py	Remove six usage	2020-05-11 10:21:58 +02:00