def handle()

in cdsresponder/cdsresponder.py [0:0]

• 23 lines of code
• 1 McCabe index (conditional complexity)

    def handle(self):
        connection = pika.SelectConnection(
            pika.ConnectionParameters(
                host=os.environ.get("RABBITMQ_HOST"),
                port=int(os.environ.get("RABBITMQ_PORT", 5672)),
                virtual_host=os.environ.get("RABBITMQ_VHOST", "/"),
                credentials=pika.PlainCredentials(username=os.environ.get("RABBITMQ_USER"), password=os.environ.get("RABBITMQ_PASSWD")),
                connection_attempts=int(os.environ.get("RABBITMQ_CONNECTION_ATTEMPTS", 3)),
                retry_delay=int(os.environ.get("RABBITMQ_RETRY_DELAY", 3))
            ),
            on_open_callback=self.channel_opened,
            on_close_callback=self.connection_closed,
            on_open_error_callback=self.connection_closed,
        )

        self.runloop = connection.ioloop

        def on_quit(signum, frame):
            logger.info("Caught signal {0}, exiting...".format(signum))
            connection.ioloop.stop()

        signal.signal(signal.SIGINT, on_quit)
        signal.signal(signal.SIGTERM, on_quit)

        connection.ioloop.start()
        logger.info("terminated")
        sys.exit(self.exit_code)