BrokerConnection is now Connection in docs

1 files changed, 2 insertions, 2 deletions

diff --git a/funtests/transport.py b/funtests/transport.py
index 76a0e010..5924a72a 100644
--- a/funtests/transport.py
+++ b/funtests/transport.py
@@ -9,7 +9,7 @@ import weakref
 
 from nose import SkipTest
 
-from kombu import BrokerConnection
+from kombu import Connection
 from kombu import Exchange, Queue
 from kombu.tests.utils import skip_if_quick
 
@@ -104,7 +104,7 @@ class TransportCase(unittest.TestCase):
             options.setdefault("userid", self.userid)
         if self.password:
             options.setdefault("password", self.password)
-        return BrokerConnection(transport=self.transport, **options)
+        return Connection(transport=self.transport, **options)
 
     def do_connect(self):
         self.connection = self.get_connection(**self.connection_options)