2008-03-27

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')

就可以了
评论
发表评论

您还没有登录，请登录后发表评论

tailorcai
搜索本博客
最近加入圈子
存档
最新评论