hornetq stomp send

import logging
logging.basicConfig()
#logging.getLogger().setLevel(logging.DEBUG)
import stomp
import random
import os

conn = stomp.Connection(host_and_ports=[('localhost',61613)],
                        version='1.1',
                        heartbeats=(1000, 3000),
                        user='radius_producer',
                        passcode='pass',
                        )
conn.start()
conn.connect()

for cnt in range(1000000):
    reclen=random.randint(160,300)
    system='wired'
    status_type=random.choice(['START','INTERIM_UPDATE','STOP'])
    realm='online'
    data=os.urandom(reclen)
    conn.send(data,
              destination='jms.topic.radius',
              #destination='/topic/radius',
              headers={
                       'content-length':reclen,
                       'persistent':'true',
                       'Xsystem':system,
                       'Xstatustype':status_type,
                       'Xrealm':realm
                     },
              )
    print cnt