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

try:
	id_vistoria = sys.argv[1]
	connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
	channel = connection.channel()


	channel.queue_declare(queue='laudo')

	channel.basic_publish(exchange='',
	                      routing_key='laudo',
	                      body=id_vistoria)
	print(" [x] Sent %r" % id_vistoria)
	connection.close()
except IndexError:
	print("Informe um ID de Proposta Vistoria")