oslo.messaging/oslo/messaging/_drivers
Mehdi Abaakouk 948c05417c Add transport reconnection retries
When a rpc client try to make a RPC call and the server is unreachable
The rpc call hang until the server come back.

In most case this is the desired behavior.

But sometimes, we can prefer that the library raise an exception after a
certain number of retries.

For example in ceilometer, when publishing a
storage.objects.incoming.bytes sample from the Swift middleware to an
AMQP topic, you might not want to block the Swift client if the AMQP broker
is unavailable - instead, you might have a queueing policy whereby
if a single reconection attempt fails we queue the sample in memory and
try again when another sample is to be published.

This patch is the oslo.messaging part that allow this.

Closes bug #1282639
Co-Authored-By: Ala Rezmerita <ala.rezmerita@cloudwatt.com>

Change-Id: I32086d0abf141c368343bf225d4b021da496c020
2014-06-13 16:21:59 +02:00
..
__init__.py Remove copyright from empty files 2014-01-04 10:33:58 +08:00
amqp.py Remove amqp default exchange hack 2014-05-28 14:12:30 +02:00
amqpdriver.py Add transport reconnection retries 2014-06-13 16:21:59 +02:00
base.py notification listener: add allow_requeue param 2014-03-03 07:51:18 -08:00
common.py Removes unused config option 2014-06-11 11:13:09 +02:00
impl_fake.py Add transport reconnection retries 2014-06-13 16:21:59 +02:00
impl_qpid.py Add transport reconnection retries 2014-06-13 16:21:59 +02:00
impl_rabbit.py Add transport reconnection retries 2014-06-13 16:21:59 +02:00
impl_zmq.py Add transport reconnection retries 2014-06-13 16:21:59 +02:00
matchmaker.py Remove vim header 2014-03-18 05:51:12 +00:00
matchmaker_redis.py remove default=None for config options 2014-05-28 09:08:51 +02:00
matchmaker_ring.py Remove vim header 2014-03-18 05:51:12 +00:00
pool.py Apply six for metaclass 2013-10-14 14:10:31 -04:00