amqp_client.py 文件源码

def __init__(self,amqp_info):
        Greenlet.__init__(self)
        ExampleConsumer.__init__(self,amqp_info)
        self.callinfos={}
        self.send_queue=Queue()
        self.lock = BoundedSemaphore(1)
        self.send_greenlet=None


        self.handle_stoping=False
        self.send_stop_evt=Event()

        self.timeout_stop_evt=Event()

        self.timeout_handle_greenlet=gevent.spawn(self.on_timeout_handle)
        self.timeout_handle_greenlet.start()