В настоящее время я играю с реализацией Java Socket.io, доступной здесь:Нетти-socketio

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

Вот мой код:

server.addEventListener("message", clientData.class, new DataListener<clientData>() {
        @Override
        public void onData(SocketIOClient client, clientData data, AckRequest ackRequest) throws Exception {
            System.out.println("Message from client: " + data.getMessage());

        }

    });



public class clientData{

String message;

public String getMessage() {
    return message;
}

public void setMessage(String message) {
    this.message = message;
}

}

По сути, я бы хотел, чтобы при получении определенного сообщения от клиента мне была нужна функция в другом классе. Я провел последние два часа, читая оObservable, Observer, Interfaces и обработчики событий, но я действительно не уверен, как это настроить.

Библиотека также упоминает об этомDataListener, но я понятия не имею, что это такое, поскольку в библиотеке мало документации.

Любой вклад или совет по этому вопросу будет принята с благодарностью.

Спасибо