3

AMQ文档指出,可以在建立连接时设置预取限制 - 有没有办法在实例化队列连接时使用stomp.py设置预取限制?

4

1 回答 1

4

我也问过自己这个问题,所以如果有人在这个问题上仍然需要帮助:

可以将 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})
于 2017-07-16T08:23:48.267 回答