diff options
| author | Josh Kearney <josh.kearney@rackspace.com> | 2010-11-22 16:48:44 -0600 |
|---|---|---|
| committer | Josh Kearney <josh.kearney@rackspace.com> | 2010-11-22 16:48:44 -0600 |
| commit | f0f990495428c028401ba9a4740e6b7a0441213c (patch) | |
| tree | cd3b4f4650baa647974b18fa5edbec71cd7a4bb8 /nova/rpc.py | |
| parent | deac609ceb1cd6e081445bfc4d8f8c3222b97774 (diff) | |
| download | nova-f0f990495428c028401ba9a4740e6b7a0441213c.tar.gz nova-f0f990495428c028401ba9a4740e6b7a0441213c.tar.xz nova-f0f990495428c028401ba9a4740e6b7a0441213c.zip | |
Use FLAGS instead of constants
Diffstat (limited to 'nova/rpc.py')
| -rw-r--r-- | nova/rpc.py | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index 57e522ad3..86a29574f 100644 --- a/nova/rpc.py +++ b/nova/rpc.py @@ -41,9 +41,6 @@ from nova import context FLAGS = flags.FLAGS -AMQP_RETRY_INT = 10 -AMQP_MAX_RETRIES = 12 - LOG = logging.getLogger('amqplib') LOG.setLevel(logging.DEBUG) @@ -86,9 +83,9 @@ class Consumer(messaging.Consumer): Contains methods for connecting the fetch method to async loops """ def __init__(self, *args, **kwargs): - for i in xrange(AMQP_MAX_RETRIES): + for i in xrange(FLAGS.rabbit_max_retries): if i > 0: - time.sleep(AMQP_RETRY_INT) + time.sleep(FLAGS.rabbit_retry_interval) try: super(Consumer, self).__init__(*args, **kwargs) self.failed_connection = False @@ -98,11 +95,11 @@ class Consumer(messaging.Consumer): " Trying again in %d seconds." % ( FLAGS.rabbit_host, FLAGS.rabbit_port, - AMQP_RETRY_INT)) + FLAGS.rabbit_retry_interval)) self.failed_connection = True if self.failed_connection: logging.exception("Unable to connect to AMQP server" \ - " after %d tries. Shutting down." % AMQP_MAX_RETRIES) + " after %d tries. Shutting down." % FLAGS.rabbit_max_retries) sys.exit(1) def fetch(self, no_ack=None, auto_ack=None, enable_callbacks=False): |