openstack/oslo.messaging
Code Issues Proposed changes
OpenStack library for messaging
2,518 Commits 13 Branches 63 Tags 36 MiB
Python 99.8%
Shell 0.2%
4d2787227b
Go to file
Gabriele 4d2787227b Retry to declare a queue after internal error 
Without this commit, the client can lose the messages, because the
client does not handler the 'AMQP internal error 541',
read here [2] for details.
The fix retries to create the queue after a delay.
When the virtual-host is ready the declare does not fail.
This is a rare condiction, please read the bug [1] for details.

Closes-Bug: #1822778

[1] https://bugs.launchpad.net/oslo.messaging/+bug/1822778
[2] https://www.rabbitmq.com/amqp-0-9-1-reference.html

Change-Id: I7ab1f9d21ebb807285bf1422bc14cc6e07dcd32a
2019-04-05 15:08:12 +02:00
doc Kafka driver deployment guide 2019-01-23 08:27:43 -05:00
etc Fix spelling typo in output 2015-09-24 18:11:22 +08:00
oslo_messaging Retry to declare a queue after internal error 2019-04-05 15:08:12 +02:00
playbooks Remove the deprecated ZeroMQ driver 2018-08-28 16:00:50 -04:00
releasenotes Update master for stable/stein 2019-03-18 14:45:21 +00:00
tools Update hacking version 2019-01-21 19:45:42 -05: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 remove feature branch from master .gitreview 2016-05-09 11:31:28 -04:00
.stestr.conf Switch to stestr 2018-07-04 08:33:49 +07:00
.zuul.yaml Merge "Change python3.5 job to python3.7 job on Stein+" 2019-02-22 01:23:52 +00:00
babel.cfg Setup for translation 2014-06-05 22:48:44 +02:00
bindep.txt Switch driver to confluent-kafka client library 2018-12-04 11:25:07 -05: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
lower-constraints.txt Bump amqp requirement version to >=2.4.1 2019-02-18 18:29:26 +01:00
README.rst Add release notes link to README 2018-06-21 13:16:36 +08:00
requirements.txt Bump amqp requirement version to >=2.4.1 2019-02-18 18:29:26 +01:00
setup-test-env-kafka.sh Switch driver to confluent-kafka client library 2018-12-04 11:25:07 -05:00
setup.cfg Merge "Switch driver to confluent-kafka client library" 2018-12-07 19:59:50 +00:00
setup.py Updated from global requirements 2017-12-13 05:01:29 +00:00
test-requirements.txt Update hacking version 2019-01-21 19:45:42 -05:00
tox.ini Merge "Change python3.5 job to python3.7 job on Stein+" 2019-02-22 01:23:52 +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.