Add send_amq.py and make workflow use ActiveMQ