ActiveMQ + Python

首先试用了pyactivemq，不过这个代码在windows下测试用例都过不去。在linux下可以测试过，但是Durable..的测试程序工作不正常，ActiveMQ总是报无法从store中回复数据。

只好试stomp库。这个库的例程有些问题。我改了一下，我希望的功能可以用。

listener应该这样写：
class MyListener(stomp.ConnectionListener):
    def on_error(self, headers, message):
        print 'received an error %s' % message
       
    def on_message(self, headers, message):
        print 'received a message %s' % message

persist消息应该这样写：
conn.send( 'message %d' % sn , destination='/queue/hbtvweb', persistent='true')

就可以了