Как добавить слушатель для OnWebSocketMessage? - PullRequest
0 голосов
/ 09 ноября 2019

Это глупый вопрос, но я не знаю, как поступить. Допустим, у меня есть сервер Jetty WebSocket, подобный этому:

@Log4j
@WebSocket
public class BackendServer {

    // Store sessions if you want to, for example, broadcast a message to all users
    private static final Queue<Session> sessions = new ConcurrentLinkedQueue<>();

    @OnWebSocketConnect
    public void connected(Session session) {
        sessions.add(session);
    }

    @OnWebSocketClose
    public void closed(Session session, int statusCode, String reason) {
        sessions.remove(session);
    }

    @OnWebSocketMessage
    public void message(Session session, String message) throws IOException, URISyntaxException {
        log.info("The WebSocket server received the message: " + message);
    }

    @OnWebSocketError
    public void throwError(Throwable error) {
        error.printStackTrace();
    }
}

Теперь я хочу, чтобы каждый раз, когда я получал сообщение, чтобы напечатать его из моего основного метода. У меня уже есть это:

public static void main(String args[]) throws IOException {

        // Start the backend server
        port(8888);
        webSocketIdleTimeoutMillis(0);
        webSocket("/socker", BackendServer.class);
        init();

Но как я могу узнать из основного метода, когда сообщение было получено? И как я могу узнать, что это было за сообщение?

Любые советы очень ценятся! Спасибо!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...