mirror of https://github.com/celery/kombu.git
commit
7c30466293
|
@ -119,7 +119,7 @@ Quick overview
|
|||
from kombu.messaging import Exchange, Queue, Consumer, Producer
|
||||
|
||||
media_exchange = Exchange("media", "direct", durable=True)
|
||||
video_queue = Queue("video", exchange=media_exchange, key="video")
|
||||
video_queue = Queue("video", exchange=media_exchange, routing_key="video")
|
||||
|
||||
# connections/channels
|
||||
connection = BrokerConnection("localhost", "guest", "guest", "/")
|
||||
|
|
Loading…
Reference in New Issue