From c7cdf2d9b7e992b3fa6ccb5435d898609b92553c Mon Sep 17 00:00:00 2001
From: Mehdi Abaakouk <sileht@redhat.com>
Date: Wed, 4 Jan 2017 07:58:26 +0100
Subject: [PATCH] kafka: fix python3 exception

Change-Id: I7244515f274719eb8e9189677554637e20917274
---
 oslo_messaging/_drivers/impl_kafka.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/oslo_messaging/_drivers/impl_kafka.py b/oslo_messaging/_drivers/impl_kafka.py
index 15f7c3d1a..a8825e4c8 100644
--- a/oslo_messaging/_drivers/impl_kafka.py
+++ b/oslo_messaging/_drivers/impl_kafka.py
@@ -191,7 +191,7 @@ class Connection(object):
         """
 
         def _raise_timeout(exc):
-            raise driver_common.Timeout(exc.message)
+            raise driver_common.Timeout(str(exc))
 
         timer = driver_common.DecayingTimer(duration=timeout)
         timer.start()