def send_missing_commission_message()

in rabbitmq/ProjectMessageProcessor.py [0:0]


def send_missing_commission_message(commission_id):
    connection = 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)
    ))
    channel = connection.channel()
    channel.queue_declare("missing-commissions")
    channel.queue_bind(exchange="pluto-atomresponder", queue="missing-commissions",
                       routing_key="atomresponder.commission.missing-id")
    logger.info("About to send commission missing id. message for commission: {0}.".format(commission_id))
    channel.basic_publish(exchange="pluto-atomresponder",
                          routing_key="atomresponder.commission.missing-id",
                          body='{"id":"%s"}' % commission_id)