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

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()
阅读 2.9k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题