跺脚.py基于持久客户端在ActiveMQ中填充订户列表

2024-09-20 03:45:53 发布

您现在位置:Python中文网/ 问答频道 /正文

我对ActiveMQ上的持久客户端有问题。我正在使用跺脚.py在Python中。在

 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…”。在

问题是每次我断开跺脚.py-基于客户端,下次再次连接时,我会得到一个新的“clientId”。这会导致ActiveMQ中的订阅服务器列表填满: alt text (上图显示了我的ActiveMQ代理上的订阅服务器。下一次断开连接时,上面的条目仍将保留,并将添加另一个条目。很快我就有很多订户在名单上了)。在

奇怪的是选择器是100%工作的(我通过更改<;>to be=,这样消息就会返回给我),所以clientId必须以某种方式工作。


Tags: py服务器clientidtrue客户端connect条目
1条回答
网友
1楼 · 发布于 2024-09-20 03:45:53

我解决了,整个事情都是因为一个简单的拼写错误。行:

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

应包含复数形式的“headers”。在

相关问题 更多 >