我按照 activemq 站点的示例启动了一个嵌入式代理:
BrokerService broker = new BrokerService();
broker.addConnector("tcp://localhost:8161");
broker.start();
然后,我向以下URL执行一些帖子以使用ActiveMQ的REST功能:
"http://localhost:8161/api/message/EventQueue?type=queue"
当我使用独立代理发送帖子时,一切正常,但是当我使用嵌入式代理时,它会挂起进程。
我正在使用活动的 mq 版本 5.8.0
我错过了什么?
谢谢
您正在添加使用 openwire 协议的 TCP 连接器,但您正在发送 post 请求,就好像它是 HTTP 连接器一样。 您需要添加一个基于 HTTP 传输的连接器,并使用该连接器来发布您的帖子。
当然,您必须确保在 http 的类路径上具有类,该类路径位于 activemq-http 捆绑包中。