python stomp 收发指定的消息

python stomp收发指定的消息

代码语言：javascript复制

# -*- coding: utf-8 -*-
import sys
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' % headers)


conn = stomp.Connection10([('localhost',61613)])  
conn.set_listener('logicServerQueue', MyListener())
conn.start()
conn.connect(wait=True)


# 发送消息到testQueue队列，指定consumerId='88.3@6006'
conn.send(body=b'hahah', destination='testQueue', headers={'consumerId': '88.3@6006'})
# 从testQueue队列中接收消息，用selector过滤，只接收consumerId = '88.3@6006'的消息
conn.subscribe(destination='testQueue', headers={'selector' : "consumerId = '88.3@6006'"})

while True:
    try:
        time.sleep(1)
    except:
        break

conn.disconnect()

time.sleep(2)
conn.disconnect()

从控制台可以看出consumerId = ‘88.3@6006’被设置到了消息的headers中

python stomp

0 人点赞