Skip to content

Commit

Permalink
refactor: let system out message more clearly
Browse files Browse the repository at this point in the history
  • Loading branch information
ShadowSunCat committed Jul 10, 2023
1 parent 1a36d3c commit c2b0c8e
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,10 +14,11 @@ public class SseService {

public SseEmitter registerSseEmitter(String playerId) {
SseEmitter emitter = new SseEmitter(60L * 1000L);
emitter.onCompletion(() -> System.out.println("SseEmitter is completed"));
emitter.onTimeout(() -> System.out.println("SseEmitter is timed out"));
emitter.onError((ex) -> System.out.println("SseEmitter got error:" + ex.getMessage()));
emitter.onCompletion(() -> System.out.printf("[%s] SseEmitter is completed%n", playerId));
emitter.onTimeout(() -> System.out.printf("[%s] SseEmitter is timed out%n", playerId));
emitter.onError((ex) -> System.out.printf("[%s] SseEmitter got error:%s%n", playerId, ex.getMessage()));
emitterMap.put(playerId, emitter);
System.out.printf("[%s] SseEmitter register success%n", playerId);
return emitter;
}

Expand All @@ -30,7 +31,7 @@ public void sendMessage(BroadcastEvent broadcastEvent) {
if (emitter == null) {
return;
}
System.out.println("send event to " + playerId + ", data: " + broadcastEvent.eventBody());
System.out.printf("[%s] send event to %s, data: %s%n", playerId, playerId, broadcastEvent.eventBody());
try {
emitter.send(broadcastEvent.eventBody());
} catch (IOException e) {
Expand Down

0 comments on commit c2b0c8e

Please sign in to comment.