Declare a queue and exchange¶
Declare a queue¶
Declare a queue with Channel.declare_queue()
:
await channel.declare_queue('my_queue') # declares queue with explicit name
declare_queue returns some parameters, which might come handy if allowing the server to generate a queue name:
declaration = await channel.declare_queue('', exclusive=True)
print(declaration.queue_name)
# something like amq.gen-3Wb1ZY42ejtq31P5LmKVkw on RabbitMQ
Declare an exchange¶
Declare an exchange with Channel.declare_exchange()
:
await channel.declare_exchange('my_exchange', 'fanout')
Bind a queue to an exchange¶
Use Channel.bind_queue()
:
await channel.bind_queue('my_queue', 'my_exchange', 'my_routing_key')
Next: Publish