Declaring HA QueuesΒΆ

The following example will create a HA queue on each node in a RabbitMQ cluster.:

import rabbitpy

with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
    with conn.channel() as channel:
        queue = rabbitpy.Queue(channel, 'example')
        queue.ha_declare()