Synnefo

    def __init__(self, debug = False, logger = None):

        for exchange in settings.EXCHANGES:

            self.chan.exchange_declare(exchange=exchange, type="direct", durable=True, auto_delete=False)

        for queue in settings.QUEUES:

            self.chan.queue_declare(queue=queue, durable=True, exclusive=False, auto_delete=False)

    parser.add_option("-c", "--cleanup-queues", action="store_true", default=False, dest="cleanup_queues",

            help="Remove from RabbitMQ all queues declared in settings.py (DANGEROUS!)")

def cleanup_queues() :

    conn = amqp.Connection( host=settings.RABBIT_HOST,

                            userid=settings.RABBIT_USERNAME,

                            password=settings.RABBIT_PASSWORD,

                            virtual_host=settings.RABBIT_VHOST)

    chan = conn.channel()

    print "Queues to be deleted: ",  settings.QUEUES

    print "Exchnages to be deleted: ", settings.EXCHANGES

    ans = raw_input("Are you sure (N/y):")

    if not ans:

        return

    if ans not in ['Y', 'y']:

        return

    for exchange in settings.EXCHANGES:

        try:

            chan.exchange_delete(exchange=exchange)

        except amqp.exceptions.AMQPChannelException as e:

            print e.amqp_reply_code, " ", e.amqp_reply_text

    for queue in settings.QUEUES:

        try:

            chan.queue_delete(queue=queue)

        except amqp.exceptions.AMQPChannelException as e:

            print e.amqp_reply_code, " ", e.amqp_reply_text

    if opts.cleanup_queues:

        cleanup_queues()

        return

EXCHANGES = (EXCHANGE_GANETI, EXCHANGE_CRON, EXCHANGE_API)

QUEUE_GANETI_EVENTS="ganeti.events"

QUEUE_CRON_CREDITS="cron.credits"

QUEUE_API_EMAIL="api.email"

QUEUE_CRON_EMAIL="cron.email"

QUEUES = (QUEUE_GANETI_EVENTS, QUEUE_CRON_CREDITS, QUEUE_API_EMAIL, QUEUE_CRON_EMAIL)