slave.py 文件源码

def reconnect(self):
        b = False
        params = pika.URLParameters(self.busaddr)
        while not b:
            try:
                log.info("Connecting to rabbitmq server at: " +
                         str(self.busaddr))
                self.connection = pika.BlockingConnection(params)
                self.channel = self.connection.channel()

                self.queue_ret = self.channel.queue_declare(self.return_queue)
                self.return_queue = self.queue_ret.method.queue

                self.signal_exchange = self.channel.exchange_declare(
                    exchange='rebus_signals', exchange_type='fanout')
                self.ret_signal_queue = self.channel.queue_declare(
                    self.signal_queue, exclusive=True)
                self.signal_queue = self.ret_signal_queue.method.queue
                self.channel.queue_bind(exchange='rebus_signals',
                                        queue=self.signal_queue)
                self.channel.basic_consume(self.signal_handler,
                                           queue=self.signal_queue,
                                           no_ack=True)
                b = True
            except pika.exceptions.ConnectionClosed:
                log.info("Failed to reconnect to RabbitMQ. Retrying..")
                time.sleep(0.5)