import time

import proton
from proton import Message
from proton.handlers import MessagingHandler
from proton.reactor import Container

from proton.utils import BlockingConnection

def AMQPsend(broker_url):
    host = broker_url.split("/",1)[0]
    topic = broker_url.split("/",1)[1]

    try:
        amqp_blk_conn = BlockingConnection(host,heartbeat=1,timeout=60)
    except:
        print("Fatal error when connecting to: "+ host + "/" + topic)
        exit(1)

    sender=amqp_blk_conn.create_sender(topic)

    while True:
        time.sleep(1)
        req = Message(body="HelloWorld!")
        sender.send(req);

AMQPsend("192.168.1.2:5672/topic://test.activemq.topic.001")