Я пытаюсь отправить сообщения 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/[email protected]/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
