From a33c761e6261347864f0284f59022c1d340611d1 Mon Sep 17 00:00:00 2001
From: Kui Shi <skuicloud@gmail.com>
Date: Wed, 25 Nov 2015 09:02:45 +0000
Subject: [PATCH] Add log info for AMQP client
If librabbitmq is installed and can be imported correctly, it will
be used as AMQP client to connect RabbitMQ. Mark it in the log file.
Change-Id: I33807df67dd2fffa13c675324c8cc7ae716a210e
Signed-off-by: Kui Shi <skuicloud@gmail.com>
---
oslo_messaging/_drivers/impl_rabbit.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py
index be41cc0f5..b0b82fade 100644
--- a/oslo_messaging/_drivers/impl_rabbit.py
+++ b/oslo_messaging/_drivers/impl_rabbit.py
@@ -491,7 +491,8 @@ class Connection(object):
if purpose == rpc_amqp.PURPOSE_SEND:
self._heartbeat_start()
- LOG.debug('Connected to AMQP server on %(hostname)s:%(port)s',
+ LOG.debug('Connected to AMQP server on %(hostname)s:%(port)s '
+ 'via [%(transport)s] client',
self.connection.info())
# NOTE(sileht): value chosen according the best practice from kombu
@@ -649,7 +650,7 @@ class Connection(object):
consumer.declare(self)
LOG.info(_LI('Reconnected to AMQP server on '
- '%(hostname)s:%(port)s'),
+ '%(hostname)s:%(port)s via [%(transport)s] client'),
self.connection.info())
def execute_method(channel):