首页 > 代码库 > python stomp activemq客户端
python stomp activemq客户端
#coding=utf-8
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)
time.sleep(2)
conn = stomp.Connection([(‘192.168.251.191‘,61613)])
conn.set_listener(‘‘, MyListener())
conn.start()
conn.connect()
# 注意,官方示例这样发送消息的 $ python simple.py hello world
#conn.send(body=‘hello,garfield! this is ‘.join(sys.argv[1:]), destination=‘/queue/test‘)
#发送消息到队列
conn.send(body=‘this is message‘), destination=‘/queue/test‘)
#发送消息到主题
conn.send(body=‘this is message‘), destination=‘/topic/testTopic‘)
#从队列接受消息
conn.subscribe(destination=‘/queue/test‘, id=1, ack=‘auto‘)
#从主题接受消息
conn.subscribe(destination=‘/topic/testTopic‘, id=1, ack=‘auto‘)
time.sleep(2)
conn.disconnect()
python stomp activemq客户端
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。