Опубликовать сообщение в ActiveMQ, используя CURL - PullRequest
Новая
       7

Опубликовать сообщение в ActiveMQ, используя CURL

0 голосов
/ 29 октября 2019

Я хочу отправить сообщение брокеру ActiveMQ с помощью Curl. На самом деле я создал брокера в java с помощью BrokerFactory: 

public BrokerService createBrokerSendReceiveMessage(String brokerSchemeUrl, String brokerName)
  throws Exception {
return BrokerFactory.createBroker(brokerSchemeUrl + brokerName);

}

Брокер работает очень хорошо, но когда я хочу отправить сообщение с помощью Curl, я получаю эту ошибку:

Транспорт: 243 - Транспортное соединение с: tcp: //127.0.0.1: 62208: сбой: java.io.IOException: Неизвестный тип данных: 97

Я использую Mac и втерминал, я пишу следующую команду: 

curl -XPOST -u admin:admin  -d 'body="Hello World"' "http://localhost:61616/demo/message/study?type=queue"

Посредник работает локально на порт 61616 и имя очереди «Study». В чем проблема? Не могли бы вы помочь мне?

1 Ответ

2 голосов
/ 29 октября 2019

Интерфейс REST ActiveMQ - это веб-приложение, которое работает во встроенном экземпляре Jetty. Похоже, вы не настроили это.

По умолчанию брокер будет прослушивать OpenWire соединения через порт 61616. Поскольку curl использует HTTP, брокер блокирует запрос.

...