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)