diff --git a/amqp/config/amq_configuration.py b/amqp/config/amq_configuration.py index 612f7f7..9f33d6d 100644 --- a/amqp/config/amq_configuration.py +++ b/amqp/config/amq_configuration.py @@ -82,10 +82,17 @@ class AMQAdapter: self.PREFIX + "consul-max-retries", fallback=5 ) - self.consul_max_retries = config.getfloat( - "CleverMicro-AMQ", self.PREFIX + "consul-initial-retry-delay", - fallback=float(os.getenv("CONSUL_INITIAL_RETRY_DELAY")) - if os.getenv("CONSUL_INITIAL_RETRY_DELAY") is not None else 0.2, + self.consul_initial_retry_delay = float(os.getenv( + "CONSUL_INITIAL_RETRY_DELAY", + config.get( + "CleverMicro-AMQ", + self.PREFIX + "consul-initial-retry-delay", + fallback="0.2" + ) + )) if os.getenv("CONSUL_INITIAL_RETRY_DELAY") is not None else config.getfloat( + "CleverMicro-AMQ", + self.PREFIX + "consul-initial-retry-delay", + fallback=0.2 ) def adapter_prefix(self) -> str: