def setup_pika_channel()

in atomresponder/master_importer.py [0:0]


    def setup_pika_channel() -> (pika.spec.Connection, pika.spec.Channel):
        conn = pika.BlockingConnection(pika.ConnectionParameters(
            host=settings.RABBITMQ_HOST,
            port=getattr(settings, "RABBITMQ_PORT", 5672),
            virtual_host=getattr(settings, "RABBITMQ_VHOST", "/"),
            credentials=pika.PlainCredentials(username=settings.RABBITMQ_USER, password=settings.RABBITMQ_PASSWORD),
            connection_attempts=getattr(settings, "RABBITMQ_CONNECTION_ATTEMPTS", 3),
            retry_delay=getattr(settings, "RABBITMQ_RETRY_DELAY", 3)
        ))

        channel = conn.channel()
        channel.exchange_declare(settings.RABBITMQ_EXCHANGE, exchange_type="topic", durable=True)
        channel.confirm_delivery()

        return conn, channel