OpenStack library for messaging
Go to file
Mehdi Abaakouk 47c6c8ebbf Fix reconnection when heartbeat is missed
When a heartbeat is missing we call ensure_connection()
that runs a dummy method to trigger the reconnection
code in kombu. But also the code is triggered only if the
channel is None.

In case of the heartbeat threads we didn't reset the channel
before reconnecting, so the dummy method doesn't do anything.

This change sets the channel to None to ensure the connection
is reestablished before the dummy method is run.

Also it replaces the dummy method by checking the kombu connection
object. So we are sure the connection is reestablished.

Closes-bug: #1493890
(cherry picked from commit I39f8cd23c5a5498e6f4c1aa3236ed27f3b5d7c9a)

Change-Id: Id98d4054ecbc787e0d44884a9e4c48e3fae803b2
2015-12-09 09:07:59 +01:00
doc/source Add FAQ entry for notifier configuration 2015-02-17 10:21:30 -05:00
etc Routing notifier 2014-01-15 04:08:18 +00:00
oslo Expose _impl_test for designate 2015-01-26 21:55:20 +00:00
oslo.messaging/locale Imported Translations from Transifex 2015-02-02 06:12:37 +00:00
oslo_messaging Fix reconnection when heartbeat is missed 2015-12-09 09:07:59 +01:00
tests Fix reconnection when heartbeat is missed 2015-12-09 09:07:59 +01:00
tools Update path to subunit2html in post_test_hook 2015-10-20 22:01:17 +09:00
.gitignore Ignore any egg and egg-info directories 2014-02-05 09:32:25 -08:00
.gitreview set defaultbranch for reviews 2015-04-06 14:55:33 +00:00
.testr.conf Allows to overriding oslotest environ var 2014-11-19 11:28:02 +01:00
CONTRIBUTING.rst Workflow documentation is now in infra-manual 2014-12-05 03:30:39 +00:00
LICENSE Add oslo.messaging project infrastructure 2013-06-15 08:43:50 +01:00
MANIFEST.in Add oslo.messaging project infrastructure 2013-06-15 08:43:50 +01:00
README.rst Update README.rst format to match expectations 2015-01-27 13:52:20 -05:00
amqp1-requirements.txt Fix gate jobs in stable/kilo (4 backports) 2015-08-28 10:39:55 +03:00
babel.cfg Setup for translation 2014-06-05 22:48:44 +02:00
openstack-common.conf Switch to oslo.middleware 2014-11-08 18:08:37 +01:00
requirements-py3.txt Updated from global requirements 2015-09-17 09:22:29 +00:00
requirements.txt Updated from global requirements 2015-09-17 09:22:29 +00:00
setup-test-env-qpid.sh Fix gate jobs in stable/kilo (4 backports) 2015-08-28 10:39:55 +03:00
setup-test-env-rabbit.sh Don't use devstack to setup our functional env 2015-06-15 10:48:39 +02:00
setup-test-env-zmq.sh Don't use devstack to setup our functional env 2015-06-15 10:48:39 +02:00
setup.cfg Add pluggability for matchmakers 2015-04-09 13:56:33 +00:00
setup.py Fix gate jobs in stable/kilo (4 backports) 2015-08-28 10:39:55 +03:00
test-requirements-py3.txt Fix gate jobs in stable/kilo (4 backports) 2015-08-28 10:39:55 +03:00
test-requirements.txt Fix gate jobs in stable/kilo (4 backports) 2015-08-28 10:39:55 +03:00
tox.ini Don't use devstack to setup our functional env 2015-06-15 10:48:39 +02:00

README.rst

Oslo Messaging Library

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