Java StompSession отправляет сообщение - Spring Boot - PullRequest
Новая
       13

Java StompSession отправляет сообщение - Spring Boot

1 голос
/ 03 мая 2019

Я пытаюсь установить соединение через веб-сокет между двумя приложениями Spring Boot;Я придерживаюсь примера кода здесь: https://github.com/eugenp/tutorials/blob/master/spring-boot-client/src/main/java/org/baeldung/websocket/client/MyStompSessionHandler.java

Из которого этот раздел прекрасно работает для меня: 

 @Override
    public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
   logger.info("New session established : " + session.getSessionId());
   session.subscribe("/topic/messages", this);
   logger.info("Subscribed to /topic/messages");
   session.send("/app/chat", getSampleMessage());
   logger.info("Message sent to websocket server");
}

Однако я не знаю, как использовать повторно session.send()вне функции afterConnected.Другими словами, я хочу одну функцию, как показано ниже: 

void sendMessage(String message){
    session.send("/app/chat", message);
}
...