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