AMQ 文档注意到,在建立连接时可以设置预取限制--在实例化队列连接时是否有一种方法可以使用stomp.py设置预取限制?
发布于 2017-07-16 08:23:48
我也问过自己这个问题,所以如果还有人在这个问题上需要帮助:
可以将ActiveMQ头添加为字典。可能的配置的完整列表是这里。
因此,例如,要做更改预取限制所需的工作,需要在订阅中添加标题:
connection = stomp.Connection()
connection.start()
connection.connect('username', 'password', wait=True)
# set callback
connection.set_listener('', self)
connection.subscribe(destination='/queue/test', id=1, ack='auto', headers={'activemq.prefetchSize': 1})https://stackoverflow.com/questions/41142531
复制相似问题