我对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中的订阅服务器列表填满: (上图显示了我的ActiveMQ代理上的订阅服务器。下一次断开连接时,上面的条目仍将保留,并将添加另一个条目。很快我就有很多订户在名单上了)。在
奇怪的是选择器是100%工作的(我通过更改<;>to be=,这样消息就会返回给我),所以clientId必须以某种方式工作。
我解决了,整个事情都是因为一个简单的拼写错误。行:
应包含复数形式的“headers”。在
相关问题 更多 >
编程相关推荐