openstack
/
oslo.messaging
Code Issues Proposed changes
OpenStack library for messaging
2,575 Commits
14 Branches
42 Tags
34 MiB
Python 99.7%
Shell 0.3%
 
 
Go to file
shenjiatong 5de11fa752 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
(cherry picked from commit 196fa877a9)
(cherry picked from commit 0a432c7fb1)
 		2020-08-25 12:21:08 +02:00
doc Introduce RabbitMQ driver documentation 2019-08-08 17:59:56 +02:00
etc Fix spelling typo in output 2015-09-24 18:11:22 +08:00
oslo_messaging Cancel consumer if queue down 2020-08-25 12:21:08 +02:00
playbooks OpenDev Migration Patch 2019-04-19 19:31:51 +00:00
releasenotes Cancel consumer if queue down 2020-08-25 12:21:08 +02:00
tools Simplify tools/test-setup.sh 2020-07-02 16:44:18 +02:00
.coveragerc Update .coveragerc after the removal of respective directory 2016-10-18 17:20:09 +05:30
.gitignore Clean up .gitignore references to personal tools 2018-10-15 11:49:38 +08:00
.gitreview Update .gitreview for stable/train 2019-09-20 16:34:16 +00:00
.stestr.conf Switch to stestr 2018-07-04 08:33:49 +07:00
.zuul.yaml Simplify tools/test-setup.sh 2020-07-02 16:44:18 +02:00
CONTRIBUTING.rst Optimize the link address 2017-04-08 22:39:02 +08:00
HACKING.rst Update URLs in documents according to document migration 2017-07-12 22:54:02 +08:00
LICENSE Add oslo.messaging project infrastructure 2013-06-15 08:43:50 +01:00
README.rst Replace git.openstack.org URLs with opendev.org URLs 2019-04-26 10:31:26 +08:00
babel.cfg Setup for translation 2014-06-05 22:48:44 +02:00
bindep.txt Simplify tools/test-setup.sh 2020-07-02 16:44:18 +02:00
lower-constraints.txt Merge "Bump the openstackdocstheme extension to 1.20" 2019-07-22 15:12:22 +00:00
requirements.txt Implement mandatory flag for RabbitMQ driver 2019-07-01 21:38:32 +02:00
setup-test-env-kafka.sh Download kafka from archive.apache.org 2019-06-10 15:35:43 +00:00
setup.cfg Add Python 3 Train unit tests 2019-07-05 14:47:53 -04:00
setup.py Updated from global requirements 2017-12-13 05:01:29 +00:00
test-requirements.txt Cap Bandit below 1.6.0 and update Sphinx requirement 2019-05-14 10:46:32 +02:00
tox.ini Update TOX/UPPER_CONSTRAINTS_FILE for stable/train 2019-09-20 16:34:21 +00:00

README.rst

Team and repository tags

image

Oslo Messaging Library

Latest Version

Downloads

The Oslo messaging API supports RPC and notifications over a number of different messaging transports.