flag for kombu connection backoff on retries

This commit is contained in:
Chris Behrens
2011-08-26 16:04:34 -07:00
parent 1c5031ca6f
commit 3c835ebe4b
2 changed files with 2 additions and 1 deletions

View File

@@ -303,6 +303,7 @@ DEFINE_string('rabbit_userid', 'guest', 'rabbit userid')
DEFINE_string('rabbit_password', 'guest', 'rabbit password')
DEFINE_string('rabbit_virtual_host', '/', 'rabbit virtual host')
DEFINE_integer('rabbit_retry_interval', 10, 'rabbit connection retry interval')
DEFINE_integer('rabbit_interval_stepping', 2, 'rabbit connection retry backoff in seconds')
DEFINE_integer('rabbit_max_retries', 12, 'rabbit connection attempts')
DEFINE_string('control_exchange', 'nova', 'the main exchange to connect to')
DEFINE_boolean('rabbit_durable_queues', False, 'use durable queues')

View File

@@ -289,7 +289,7 @@ class Connection(object):
self.queues = []
self.max_retries = FLAGS.rabbit_max_retries
self.interval_start = FLAGS.rabbit_retry_interval
self.interval_stepping = 0
self.interval_stepping = FLAGS.rabbit_interval_stepping
self.interval_max = FLAGS.rabbit_retry_interval
self.params = dict(hostname=FLAGS.rabbit_host,