Отправка сообщения в RabbitMq с помощью STOMP (glassfish.tyrus.client) - PullRequest
Новая
       21

Отправка сообщения в RabbitMq с помощью STOMP (glassfish.tyrus.client)

0 голосов
/ 04 июля 2019

После успешного подключения к RabbitMq через STOMP в Java (с использованием org.glassfish.tyrus.client.ClientManager) и отправки текстового сообщения без ошибок ничего не появляется в очереди. 

String url = "ws://127.0.01:15674/ws";
ClientEndpointConfig cec = ClientEndpointConfig.Builder.create().build();
ClientManager client = ClientManager.createClient();
client.getProperties().put(ClientProperties.CREDENTIALS, new Credentials("test", "test"));
session = client.connectToServer(extends Endpoint, cec, new URI(url));
session.getBasicRemote().sendText(message, true);

В Rabbit у меня малоочереди и несколько обменов (прямые и тематические), но я не знаю, как / где их разместить.Также, возможно, я должен поставить учетные данные другим способом?

PS Расширение RabbitMq STOMP установлено и выглядит хорошо, в прослушивающих портах управления RabbitMq показывается протокол stomp в списке, но с другим портом (61613), когда я пытаюсь использоватьэтот порт я получаю javax.websocket.DeploymentException: Handshake response not received.

...