Skip to content

Latest commit

 

History

History
10 lines (8 loc) · 384 Bytes

ha_queues.rst

File metadata and controls

10 lines (8 loc) · 384 Bytes

Declaring HA Queues

The following example will create a HA :pyqueue <rabbitpy.queue.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()