python - 基于 stomp.py 的持久客户端填充 ActiveMQ 中的订阅者列表

Question

我对 ActiveMQ 上的持久客户端有疑问。我在 Python 中使用 stomp.py。

 conn.start()
 conn.connect(wait=True, header = {'client-id': 'myhostname' })
 conn.subscribe(
            '/topic/testTopic', ack='auto',
            headers = {
                'activemq.subscriptionName': 'myhostname',
                'selector': "clientid <> '%s'" % 'myhostname'
            }
)

正如您从我的代码中看到的，我将我的 clientId 设置为我自己的主机名。如所附屏幕截图(下方)所示，clientId 显示为类似于“ID:Atlas...”的内容。

问题是，每次我断开基于 stomp.py 的客户端时，下次我再次连接时都会得到一个新的“clientId”。这会导致 ActiveMQ 中的订阅者列表填满: (上图显示了我的 ActiveMQ 代理上的订阅者。下次我断开连接然后连接时，上面的条目仍将保留，并且会添加另一个。很快我的列表中就有很多订阅者)。

奇怪的是选择器 100% 有效(我通过将 <> 更改为 = 来验证这一点，以便消息返回给我)，因此 clientId 必须以某种方式工作。

Answer 1

我解决了，整个事情都是由于一个简单的拼写错误造成的。线路:

conn.connect(wait=True, header = {'client-id': 'myhostname' })

应该包含复数形式的'headers'。