我对Qpid Proton中最微不足道的一步有一个问题。这是我的设置
qpid-config -a localhost:5672 add exchange test.announce
qpid-config -a localhost:5672 add queue test.announce.q
qpid-config -a localhost:5672 bind test.announce test.announce.q(没有特意指定路由键)当我使用以下命令运行proton cpp服务器和客户端时
./server -a amqp://127.0.0.1:5672/test.announce
./client -a amqp://127.0.0.1:5672/test.announce.q客户端无法与服务器通信。但是使用独立的qpid工具
qpid-receive -a test.announce.q -b 127.0.0.1:5672 -t -f
echo "hello world!!!"|qpid-send -b 127.0.0.1:5672 -a test.announce -m 1 --content-stdin这与预期的一样。在Proton服务器上运行qpid-send似乎也运行得很好。我在Proton message API中看不到任何可以更新的内容,也不确定这里遗漏了什么。服务器和客户端代码与0.12快照中的代码基本相同。有什么想法吗?
发布于 2016-02-10 13:34:07
我意识到了我的错误。在AMQP中,服务器和客户端的概念似乎有点颠倒。我更改了应用程序,以便客户端在交换时“发送”,而服务器监听队列,一切都正常工作。
./server -a amqp://127.0.0.1:5672/test.announce.q
./client -a amqp://127.0.0.1:5672/test.announcehttps://stackoverflow.com/questions/35297720
复制相似问题