producer.py

#!/usr/bin/python

import time
import sys

import stomp


class MyListener(object):
    def on_error(self, headers, message):
        print 'received an error %s' % message

#conn = stomp.Connection(host_and_ports=[('queue-server.int', 61613)], timeout=10)
conn = stomp.Connection(host_and_ports=[('queue-server.int', 61613)]  )
conn.set_listener('', MyListener())
conn.start()
conn.connect()


data = "x" * 1024 * 1024
number = 1000
print "producing %s %s kb messages" % (number, len(data) / 1024)
for i in range(number):
    print "Inserting message number: %s " % (i+1)
    #time.sleep(0.1)
    conn.send(data, destination='/queue/testqueue')

time.sleep(2)
conn.disconnect()