使用stomp.py向activemq发送消息后台不显示
使用stomp.py向activemq发送消息后台不显示
# 推送到队列queue
def send_to_queue(msg):
conn = stomp.Connection10([('192.168.0.143', 61613)])
conn.start()
conn.connect('admin', 'admin')
conn.send(queue_name, msg)
conn.disconnect()
还有一个很奇怪的问题如果连续调用发送和接收方法,是会接收到消息并打印,但是如果先执行发送在执行接收,就接收不到消息了
##从队列接收消息
def receive_from_queue():
conn = stomp.Connection10([('192.168.0.143', 61613)])
listener = SampleListener(conn)
conn.set_listener(listener_name, listener)
conn.start()
conn.connect('admin', 'admin')
conn.subscribe(queue_name)
time.sleep(1) # secs
conn.unsubscribe(queue_name)
conn.disconnect()
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论