Pika test

pk.py

import pika
import json


class Connection(object):
    """singleton pika connection"""
    _connection = None

    @staticmethod
    def get_shared_connection():
        if not Connection._connection:
            parameters = pika.URLParameters('amqp://lakshmi:[email protected]:5672/%2F')
            Connection._connection = pika.BlockingConnection(parameters)
        return Connection._connection

for i in range(3):
    connection = Connection.get_shared_connection()
    channel = connection.channel()
    queue = 'app-name-drupal7-' + str(i)
    channel.queue_declare(queue=queue)
    for method_frame, properties, body in channel.consume(queue = queue):
        payload = json.loads(body)
        print json.dumps(payload)
        channel.basic_ack(method_frame.delivery_tag)
        if method_frame.delivery_tag == 1:
            break
    channel.queue_delete(queue=queue)