def __init__(self, app=None):
    self.app = app
    self.mailbox = self.Mailbox(app.conf.control_exchange, type='fanout', accept=['json'], producer_pool=lazy((lambda : self.app.amqp.producer_pool)), queue_ttl=app.conf.control_queue_ttl, reply_queue_ttl=app.conf.control_queue_ttl, queue_expires=app.conf.control_queue_expires, reply_queue_expires=app.conf.control_queue_expires)
    register_after_fork(self, _after_fork_cleanup_control)
def __init__(self, app=None):
    self.app = app
    self.mailbox = self.Mailbox(app.conf.control_exchange, type='fanout', accept=['json'], producer_pool=lazy((lambda : self.app.amqp.producer_pool)), queue_ttl=app.conf.control_queue_ttl, reply_queue_ttl=app.conf.control_queue_ttl, queue_expires=app.conf.control_queue_expires, reply_queue_expires=app.conf.control_queue_expires)
    register_after_fork(self, _after_fork_cleanup_control)