Плагин Qpid Broker-J Websocket AMQP 1.0 - PullRequest
Новая
       37

Плагин Qpid Broker-J Websocket AMQP 1.0

0 голосов
/ 25 марта 2019

Я пытаюсь отправить сообщения AMQP 1.0 на работающий экземпляр Qpid Broker-J из браузера с помощью rhea.js . Мне удалось отправлять и получать сообщения с версией node.js.

Я думаю, мне придется добавить / активировать плагин Websocket , я просто не могу найти документацию о том, где и как это сделать.

Кто-нибудь делал это до сих пор?

Вот мой фрагмент версии браузера: 

var server = "ws://localhost:5673";
var client = require("rhea");

client.options.username = "guest";
client.options.password = "guest";

client.on("message", function (context) {
  console.log(context.message.body);
});

var ws = client.websocket_connect(WebSocket);
var connection = client.connect({"connection_details":ws(server, ["binary", "AMQPWSB10", "amqp"]), "reconnect":false});
connection.open_receiver("examples");
var sender = connection.open_sender("examples");

function send(body) {
  sender.send({ body });
}

function sendMessage() {
  console.log("sendMessage");
  const message = document.getElementById("message").value;
  send(message);
}
<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8">
  <meta name="viewport" content="width=device-width, initial-scale=1.0">
  <meta http-equiv="X-UA-Compatible" content="ie=edge">
  <title>Document</title>
  <script src="https://cdn.jsdelivr.net/npm/rhea@1.0.2/dist/rhea.js"></script>
</head>
<body>
  <div>
    <input type="text" id="message" />
    <button type="button" onClick="sendMessage()" />send</button>
  </div>
</body>
</html>

Используя этот скрипт, я получаю Error during Websocket handshake: 

WebSocket connection to 'ws://localhost:5673/' failed: Error during WebSocket handshake: net::ERR_CONNECTION_RESET

1 Ответ

0 голосов
/ 26 марта 2019

Хорошо, я понял это. Плагин уже активирован, вам просто нужно добавить порт в веб-интерфейсе управления брокером или непосредственно в конфигурации. Для любого, кто ищет это, посмотрите под Брокером> Порты> Добавить Порт.

...