Post 使用 CURL 向 ActiveMQ 发送消息
Post a message to ActiveMQ using CURL
我想 post 使用 Curl 向 ActiveMQ 代理发送消息。实际上我在 java 中通过 BrokerFactory 创建了一个代理:
public BrokerService createBrokerSendReceiveMessage(String brokerSchemeUrl, String brokerName)
throws Exception {
return BrokerFactory.createBroker(brokerSchemeUrl + brokerName);
}
代理工作得很好,但是当我想用 Curl 发送消息时,我收到了这个错误:
Transport:243 - Transport Connection to: tcp://127.0.0.1:62208 failed: java.io.IOException: Unknown data type: 97
我使用 Mac 并在终端中编写以下命令:
curl -XPOST -u admin:admin -d 'body="Hello World"' "http://localhost:61616/demo/message/study?type=queue"
代理在本地端口 61616 上运行,队列名称为 "study"。
问题是什么?你能帮帮我吗?
ActiveMQ 的 REST 接口是一个在嵌入式 Jetty 实例中运行的 Web 应用程序。您似乎没有配置它。
默认情况下,代理将在端口 61616
上侦听 OpenWire 连接。由于 curl
使用 HTTP,代理会阻塞请求。
我想 post 使用 Curl 向 ActiveMQ 代理发送消息。实际上我在 java 中通过 BrokerFactory 创建了一个代理:
public BrokerService createBrokerSendReceiveMessage(String brokerSchemeUrl, String brokerName)
throws Exception {
return BrokerFactory.createBroker(brokerSchemeUrl + brokerName);
}
代理工作得很好,但是当我想用 Curl 发送消息时,我收到了这个错误:
Transport:243 - Transport Connection to: tcp://127.0.0.1:62208 failed: java.io.IOException: Unknown data type: 97
我使用 Mac 并在终端中编写以下命令:
curl -XPOST -u admin:admin -d 'body="Hello World"' "http://localhost:61616/demo/message/study?type=queue"
代理在本地端口 61616 上运行,队列名称为 "study"。 问题是什么?你能帮帮我吗?
ActiveMQ 的 REST 接口是一个在嵌入式 Jetty 实例中运行的 Web 应用程序。您似乎没有配置它。
默认情况下,代理将在端口 61616
上侦听 OpenWire 连接。由于 curl
使用 HTTP,代理会阻塞请求。