notebook.community
Edit and run
In [ ]: import rabbitpy
import rabbitpy
In [ ]: with rabbitpy.Connection() as connection: with connection.channel() as channel: queue = rabbitpy.Queue(channel, 'bound-queue') queue.bind('amq.topic', '#')
with rabbitpy.Connection() as connection: with connection.channel() as channel: queue = rabbitpy.Queue(channel, 'bound-queue') queue.bind('amq.topic', '#')