diff --git a/src/main/java/mafia/mafiatogether/game/application/GameEventListener.java b/src/main/java/mafia/mafiatogether/game/application/GameEventListener.java index cd13edfa..d59b051a 100644 --- a/src/main/java/mafia/mafiatogether/game/application/GameEventListener.java +++ b/src/main/java/mafia/mafiatogether/game/application/GameEventListener.java @@ -103,7 +103,6 @@ public void listenDeleteGameEvent(final DeleteGameEvent deleteGameEvent) { chatRepository.deleteById(code); voteRepository.deleteById(code); sendStatusChangeEventToSseClient(code, StatusType.WAIT); - sseEventPublisher.disconnectSseByCode(code); gameRepository.deleteById(code); final Lobby room = lobbyRepository.findById(code) @@ -141,6 +140,9 @@ public void listenDeleteLobbyEvent(final DeleteLobbyEvent deleteLobbyEvent) { @EventListener public void listenGameStatusChangeEvent(final GameStatusChangeEvent gameStatusChangeEvent) { + if (gameStatusChangeEvent.statusType().equals(StatusType.DELETED)) { + return; + } sendStatusChangeEventToSseClient(gameStatusChangeEvent.code(), gameStatusChangeEvent.statusType()); }