publisher.py 文件源码

def connect(self):
        if not self._connection or self._connection.is_closed:
            LOGGER.info('Connecting to %s', self._url)
            self._connection = pika.BlockingConnection(pika.URLParameters(self._url))
            return pika.SelectConnection(pika.URLParameters(self._url),
                                         on_open_callback=self.on_connection_open,
                                         on_close_callback=self.on_connection_closed,
                                         stop_ioloop_on_close=False)