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')
就可以了
页:
[1]