使用stomp.py向activemq发送消息后台不显示

发布于 2022-09-07 20:38:12 字数 782 浏览 16 评论 0

使用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()

clipboard.png

还有一个很奇怪的问题如果连续调用发送和接收方法,是会接收到消息并打印,但是如果先执行发送在执行接收,就接收不到消息了

##从队列接收消息
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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文