3

我对 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 必须以某种方式工作。

4

1 回答 1

3

我解决了，整个事情是由于一个简单的拼写错误。该行：

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

应包含复数形式的“标题”。

于 2010-09-25T20:17:19.280 回答