Page History

@Override
public AbstractActor.Receive createReceive() {
    return receiveBuilder()
            .match(ConnectInfo.class, c -> {
                if(c.getCmd()== ConnectInfo.Cmd.CONNECT){
                    sessionMgr.put(c.getSessionId(),c.getWsSender());
                    log.info("user connected:"+c.getSessionId());
                }else if(c.getCmd()== ConnectInfo.Cmd.DISCONET){
                    sessionMgr.remove(c.getSessionId());
                    Player removeUser = new Player();
                    removeUser.setSession(c.getSessionId());

                    if(c.getTableNo()>0){
                        findTableByID(c.getTableNo()).tell(new SeatOut(removeUser),ActorRef.noSender());
                    }else{
                        findTableALL().tell(new SeatOut(removeUser),ActorRef.noSender());
                    }
                    log.info("user disconnected:"+c.getSessionId());
                }
                sessionMgr.put(c.getSessionId(),c.getWsSender());
            })
            .match(TableCreate.class, t->{
                // Create a table under the lobby, if you have an Actor named TableManagement, you can move easily.
                String tableUID = "table-" + t.getTableId();
                if(t.getCmd() == TableCreate.Cmd.CREATE){
                    ActorRef tableActor = getContext().actorOf( TableActor.props(t,this.getSelf() ), tableUID);
                    tableActor.tell(t,ActorRef.noSender());
                }
            })
            .match(JoinGame.class, j->{
                joinGameTable(j.getTableId(),j.getName(),j.getSession());
            })
            .match(MessageWS.class, m->{
                send(m.getSession(),m.getGameMessage());
            })
            .build();
}

private ActorRef findTableByID(int tableID) throws Exception {
    String tableActorPath = "/user/lobby/table-"+tableID;
    ActorSelection tableSelect = this.getContext().actorSelection(tableActorPath);
    FiniteDuration duration = FiniteDuration.create(1, TimeUnit.SECONDS);
    Future<ActorRef> fut = tableSelect.resolveOne(duration);
    ActorRef tableActor = Await.result(fut, duration);
    return tableActor;
}