0

我按照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

我错过了什么?

谢谢

4

1 回答 1

0

您正在添加一个使用 openwire 协议的 TCP 连接器,但您正在发送 post 请求,就好像它是一个 HTTP 连接器一样。您需要添加一个基于 HTTP 传输的连接器并使用该连接器来发布您的帖子。

当然,您必须确保在 activemq-http 包中的 http 类路径上有类。

于 2013-12-29T12:09:00.743 回答