Mehdi Abaakouk 415db68b67 rabbit: redeclare consumers when ack/requeue fail
In case the acknowledgement or requeue of a message fail,
the kombu transport can be disconnected

In this case, we must redeclare our consumers.

This changes fixes that.

This have no tests because the kombu memory transport we use in our tests
cannot be in disconnected state.

Closes-bug: #1448650

Change-Id: I5991a4cf827411bc27c857561d97461212a17f40
2015-05-12 10:19:42 +02:00
2014-01-15 04:08:18 +00:00
2015-01-26 21:55:20 +00:00
2015-05-11 08:29:34 +02:00
2015-03-12 16:38:51 -07:00
2014-06-05 22:48:44 +02:00
2015-04-07 09:18:52 -07:00
2015-03-19 03:03:53 -07:00
2014-04-30 02:45:47 +00:00
2015-03-16 01:46:07 +00:00

Oslo Messaging Library

Latest Version

Downloads

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

Description
OpenStack library for messaging
Readme 36 MiB
Languages
Python 99.8%
Shell 0.2%