mirror of https://github.com/celery/kombu.git
README: Fixed typo Connection -> BrokerConnection
This commit is contained in:
parent
71a8d2f39f
commit
d8602b1415
|
@ -8,14 +8,14 @@
|
||||||
|
|
||||||
Proposed API::
|
Proposed API::
|
||||||
|
|
||||||
from kombu.connection Connection
|
from kombu.connection BrokerConnection
|
||||||
from kombu.messaging import Exchange, Binding, Consumer, Producer
|
from kombu.messaging import Exchange, Binding, Consumer, Producer
|
||||||
|
|
||||||
media_exchange = Exchange("media", "direct", durable=True)
|
media_exchange = Exchange("media", "direct", durable=True)
|
||||||
video_binding = Binding("video", exchange=media_exchange, key="video")
|
video_binding = Binding("video", exchange=media_exchange, key="video")
|
||||||
|
|
||||||
# connections/channels
|
# connections/channels
|
||||||
connection = Connection("localhost", "guest", "guest", "/")
|
connection = BrokerConnection("localhost", "guest", "guest", "/")
|
||||||
channel = connection.channel()
|
channel = connection.channel()
|
||||||
|
|
||||||
# produce
|
# produce
|
||||||
|
|
Loading…
Reference in New Issue