gistfile1.txt

// I think ideally the RequestContext should not be a parameter in all the methods
// but i don't want to discuss that part right now

public void handleCreateRequests(RequestContext context, RaptorV2Message msg) {
       Log.info("HandleCreateRequests", context);
       Session session = getSession(msg.sessionId());   // <-- see it is not ctx.sessionId()
       Connectino connection = getConnection(msg);
       CompletableFuture.runAsync(() -> onSessionConnectRequest(context, session, connection), getExecutor(msg));
}

public void onSessionConnectRequest(RequestContext context, Session session, Connection connection) {
       Log.info("OnSessionConnectRequest", context);
       CompletableFuture<Token> future = AnvilApi.validateToken();
       future.thenAsync(token -> handleSessionConnectRequest(context, session, connection), THIS_CONTEXT);
}

public void handleSessionConnectRequest(RequestContext context, Session session, Connection connection) {
       Log.info("HandleSessionConnectRequest", context);
       session.add(connection);
}