reprocess.py

import pika
parameters = pika.URLParameters('STUFF HERE')
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.queue_declare(queue='socorro.priority', durable=True)
with open('/tmp/uuid_list1000', 'r') as file:
        for uuid in file.read().splitlines():
                channel.basic_publish(exchange='', routing_key="socorro.priority", body=uuid, properties=pika.BasicProperties(delivery_mode=2))
                print 'done with', uuid
connection.close()