例：まとめて実装する

SocketIOServer server = new SocketIOServer(config);

// 接続
server.addConnectListener(client ->
    log.info("Connected: {}", client.getSessionId())
);

// チャットをリッスン
server.addEventListener("chat", ChatPayload.class,
    (client, payload, ack) -> {
        // すべての人にブロードキャスト
        server.getBroadcastOperations().sendEvent("chat", payload);
    }
);

// 部屋に参加
server.addEventListener("join", String.class,
    (client, roomName, ack) -> {
        client.joinRoom(roomName);
    }
);

server.start();

---

参照

• https://socket.io/docs/v4/emitting-events/