Add SessionReader and SessionWriter worker threads for session #198
@@ -26,9 +26,9 @@ public class ServerApp {
|
|||||||
logger.info("Starting server at port {}", port);
|
logger.info("Starting server at port {}", port);
|
||||||
|
|
||||||
EventBus eventBus = new EventBus();
|
EventBus eventBus = new EventBus();
|
||||||
SessionManager sessionManager = new SessionManager();
|
SessionManager sessionManager = new SessionManager(eventBus);
|
||||||
eventBus.subscribe(
|
eventBus.subscribe(
|
||||||
DisconnectEvent.class, event -> sessionManager.removeSession(event.sessionId()));
|
DisconnectEvent.class, event -> sessionManager.onDisconnect(event));
|
||||||
NetworkManager networkManager = new NetworkManager(port, sessionManager, eventBus);
|
NetworkManager networkManager = new NetworkManager(port, sessionManager, eventBus);
|
||||||
|
|
||||||
UserRegistry userRegistry = new UserRegistry();
|
UserRegistry userRegistry = new UserRegistry();
|
||||||
|
|||||||
Reference in New Issue
Block a user