#!/usr/bin/env python
import pika, sys

try:
    id_proposta = sys.argv[1]
    id_liquidacao = sys.argv[2]
    message = str(id_proposta) + ',' + str(id_liquidacao)
    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
    channel = connection.channel()

    channel.queue_declare(queue='mail')

    channel.basic_publish(exchange='', routing_key='mail', body=message)

    connection.close()
except IndexError:
    print("Informe um ID de Proposta e/ou ID de Liquidacao")