import time
import sys
import stomp
class MyListener(object):
def on_error(self, headers, message):
print('received an error %s' % message)
def on_message(self, headers, message):
print('received a message %s' % message)
#官方示例的连接代码也落后了，现在分协议版本
conn = stomp.Connection10([('ip...',61613)])
conn.set_listener('',MyListener())conn.start()conn.connect()conn.subscribe(destination='/queue/test', id=1, ack='auto')
#注意，官方示例这样发送消息是有问题的
#conn.send(body='hello,garfield! this is'.join(sys.argv[1:]),destination='/queue/test')
conn.send(body='hello,garfield!',destination='/queue/test')
time.sleep(2)
conn.disconnect()python搭建ActiveMQ
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- 搭建环境为阿里云 CenterOS 7.0 64位,Git服务器自带版本号为 1.8.3.1 Git服务器搭建与配...
- virtualenv 的作用相当于 Sandbox，它通过隔离包目录和系统环境参数来实现多个相对独立的虚拟环境。如...
- 一、安装python3.4 (CentOS6.5) 这里我们选择python3.4版本，首先是因为pytho...
- 版权声明：本文为博主原创文章，未经博主允许不得转载。 PS:转载请注明出处作者:TigerChain地址:http...
- 发现很多人连环境都不会搭，虽然这个问题没有什么技术含量，但博主也决定写点东西给那些环境都不会搭建的小白。 关于se...
