BrokerConnection is now Connection in docs

1 files changed, 12 insertions, 12 deletions

diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py
index 1ab6175a..e07b8c45 100644
--- a/examples/simple_task_queue/client.py
+++ b/examples/simple_task_queue/client.py
@@ -5,25 +5,25 @@ from kombu.pools import producers
 
 from queues import task_exchange
 
-priority_to_routing_key = {"high": "hipri",
-                           "mid": "midpri",
-                           "low": "lopri"}
+priority_to_routing_key = {'high': 'hipri',
+                           'mid': 'midpri',
+                           'low': 'lopri'}
 
 
-def send_as_task(connection, fun, args=(), kwargs={}, priority="mid"):
-    payload = {"fun": fun, "args": args, "kwargs": kwargs}
+def send_as_task(connection, fun, args=(), kwargs={}, priority='mid'):
+    payload = {'fun': fun, 'args': args, 'kwargs': kwargs}
     routing_key = priority_to_routing_key[priority]
 
     with producers[connection].acquire(block=True) as producer:
         maybe_declare(task_exchange, producer.channel)
-        producer.publish(payload, serializer="pickle",
-                                  compression="bzip2",
+        producer.publish(payload, serializer='pickle',
+                                  compression='bzip2',
                                   routing_key=routing_key)
 
-if __name__ == "__main__":
-    from kombu import BrokerConnection
+if __name__ == '__main__':
+    from kombu import Connection
     from tasks import hello_task
 
-    connection = BrokerConnection("amqp://guest:guest@localhost:5672//")
-    send_as_task(connection, fun=hello_task, args=("Kombu", ), kwargs={},
-                 priority="high")
+    connection = Connection('amqp://guest:guest@localhost:5672//')
+    send_as_task(connection, fun=hello_task, args=('Kombu', ), kwargs={},
+                 priority='high')