Stomp ActiveMQ вопросы

Question

Я новичок в Stomp ActiveMQ. Я хочу создать логин из Android-клиента, и я не знаю, как использовать ActiveMq. Я установил активный mq, настроил stomp и запустил пример stompex. 1. У меня ошибка при запуске active mq из командной строки, если я добавляю в activemq.xml следующую строку:

 <transportConnector name="stomp+nio" uri="stomp+nio://localhost:61612"/>
            <transportConnector name="stomp+ssl" uri="stomp+ssl://localhost:61612"/>

1. Может кто-нибудь объяснить, что такое с tx1 и tx2? Есть ли способ отправить в очередь сообщение конкретному клиенту? как?

   connection.connect ("система", "менеджер");

       connection.begin("tx1");
       connection.send("/queue/test", "message1");
       connection.send("/queue/test", "message2");
       connection.commit("tx1");
   
       connection.subscribe("/queue/test", Subscribe.AckModeValues.CLIENT);
   
       connection.begin("tx2");
   
       StompFrame message = connection.receive();
       System.out.println(message.getBody());
       connection.ack(message, "tx2");
   
       message = connection.receive();
       System.out.println(message.getBody());
       connection.ack(message, "tx2");
   
       connection.commit("tx2");
   
       connection.disconnect();
   

2. Может кто-нибудь подскажите, пожалуйста, как создать приложение, которое отправляет в очередь текст, содержащий имя пользователя, пароль и получает ответ, если регистрация прошла успешно?

Answer 1

Необходимо настроить транспортные соединители с разными номерами портов, они не могут совместно использовать порт 61612. Ваша конфигурация - создать соединитель Stomp NIO и другой соединитель Stomp SSL.

Вы не можете отправлять сообщения отдельному клиенту, вы просто помещаете их в очередь и, если есть подписчик, он получит сообщение, такова природа обмена сообщениями на основе очереди. TX1 TX2 отправляет сообщения внутри транзакции.

Рекомендуем потратить некоторое время на чтение JMS Messaging, спецификации Stomp и некоторых других руководств по обмену сообщениями.