Correctly pass in False for passive kwarg, also log all the exchange
options.
@@ -47,14 +47,14 @@ def _do_register_exchange(exchange, connection, channel, retry_wrapper):
'auto_delete': exchange.auto_delete,
'arguments': exchange.arguments,
'nowait': False,
- 'passive': None
+ 'passive': False
}
# Use the retry wrapper to increase resiliency in recoverable errors.
retry_wrapper.ensured(connection=connection,
obj=channel,
to_ensure_func=channel.exchange_declare,
**kwargs)
- LOG.debug('registered exchange %s.', exchange.name)
+ LOG.debug('Registered exchange %s (%s).' % (exchange.name, str(kwargs)))
except Exception:
LOG.exception('Failed to register exchange: %s.', exchange.name)
