python 发送和接收ActiveMQ消息的实例

pip install stomp.py

# -*-coding:utf-8-*-import stompimport time  queue_name = '/queue/SampleQueue'topic_name = '/topic/SampleTopic'listener_name = 'SampleListener' class SampleListener(object):  def on_message(self, headers, message):    print 'headers: %s' % headers    print 'message: %s' % message # 推送到队列queuedef send_to_queue(msg):  conn = stomp.Connection10([('127.0.0.1',61613)])  conn.start()  conn.connect()  conn.send(queue_name, msg)  conn.disconnect() #推送到主题def send_to_topic(msg):  conn = stomp.Connection10([('127.0.0.1',61613)])  conn.start()  conn.connect()  conn.send(topic_name, msg)  conn.disconnect() ##从队列接收消息def receive_from_queue():  conn = stomp.Connection10([('127.0.0.1',61613)])  conn.set_listener(listener_name, SampleListener())  conn.start()  conn.connect()  conn.subscribe(queue_name)  time.sleep(1) # secs  conn.disconnect() ##从主题接收消息def receive_from_topic():  conn = stomp.Connection10([('127.0.0.1',61613)])  conn.set_listener(listener_name, SampleListener())  conn.start()  conn.connect()  conn.subscribe(topic_name)  while 1:    send_to_topic('topic')    time.sleep(3) # secs   conn.disconnect() if __name__=='__main__':  # send_to_queue('len 123')  # receive_from_queue()   receive_from_topic()