我也问过自己这个问题,所以如果有人仍然需要帮助解决这个问题:
可以将 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})
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
1553 次 |
| 最近记录: |