跟随wiki页面https://cwiki.apache.org/qpid/amqp-java-jms-messaging-client.html到https://cwiki.apache.org/qpid/connection-url-format.html.
简单地说,我希望qpid-aqp-1-0-client-jms-0.20-sources.jar接受URI格式,但它似乎忽略了所有内容,尤其是"brokerlist"选项?
例如:
amqp://guest:guest@nowhere?brokerlist='tcp://localhost:5672;tcp://localhost:15672'&failover='roundrobin'
但是ConnectionFactory坚持使用<clientid>
作为代理主机,并为其添加默认端口
我肯定我错过了一些非常明显的东西。。。
Broker是ActiveMQ 5.8.0,BTW.
您正在使用的连接字符串是AMQP 1.0之前的版本,新的连接字符串应该是以下格式,没有brokerlist
amqp://guest:guest@哪儿也没有?远程主机=默认
您的url中缺少虚拟主机:amqp://guest:guest@clientid/host?