Shared kombu connection

shared_connection.py

import eventlet
eventlet.monkey_patch()

from kombu import Exchange, Queue
from kombu.messaging import Consumer

exchange = Exchange('exchange', type='direct')
queue = Queue('queue', exchange, routing_key='queue')

if __name__ == '__main__':
    from kombu import Connection

    connection = Connection('amqp://guest:guest@localhost:5672//')

    def handle_message(body, message):
        print body
        message.ack()

    def run():
        with connection.channel() as channel:
            with Consumer(channel, queue,
                          accept=['json'],
                          callbacks=[handle_message]):
                connection.drain_events(timeout=10)

    w1 = eventlet.spawn(run)
    w2 = eventlet.spawn(run)
    w1.wait()
    w2.wait()

Raises:

RuntimeError: Second simultaneous read on fileno 4 detected.  Unless you really know what you're doing, make sure that only one greenthread can read any particular socket.  Consider using a pools.Pool. If you do know what you're doing and want to disable this error, call eventlet.debug.hub_prevent_multiple_readers(False) - MY THREAD=<built-in method switch of GreenThread object at 0x10542bd70>; THAT THREAD=FdListener('read', 4, <built-in method switch of GreenThread object at 0x10542bcd0>, <built-in method throw of GreenThread object at 0x10542bcd0>)