[backend] throw websocket events for game_status_change & round_statu…

…s_change #12
The-Microservice-Dungeon · Jan 24, 2022 · 3f1687a · 3f1687a
1 parent 40ec2ce
commit 3f1687a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/backend/src/main/java/thkoeln/dungeon/eventconsumer/game/GameEventConsumer.java b/backend/src/main/java/thkoeln/dungeon/eventconsumer/game/GameEventConsumer.java
@@ -48,7 +48,7 @@ public void consumeGameStatusEvent(@Header String eventId,
             gameStatusEventRepository.save(gameStatusEvent);
             logger.info("saved game event with status " + gameStatusEvent.getStatus().toString());
             gameApplicationService.gameStatusExternallyChanged(gameStatusEvent.getGameId(), gameStatusEvent.getStatus());
-            this.template.convertAndSend("game_events", "Game " + gameStatusEvent.getGameId() + " changed its Status to: " + gameStatusEvent.getStatus());
+            this.template.convertAndSend("game_events", "game_status_change");
         } catch (Exception e) {
             this.kafkaErrorService.newKafkaError("status", payload, e.getMessage());
         }
@@ -62,6 +62,7 @@ public void consumeRoundStatusEvent(@Header String eventId, @Header String times
             roundStatusEventRepository.save(roundStatusEvent);
             logger.info("saved round event with status "+roundStatusEvent.getRoundStatus().toString());
             gameApplicationService.roundStatusExternallyChanged(roundStatusEvent.getEventId(), roundStatusEvent.getRoundNumber(), roundStatusEvent.getRoundStatus());
+            this.template.convertAndSend("game_events", "round_status_change");
         } catch (KafkaException e) {
             this.kafkaErrorService.newKafkaError("roundStatus", payload, e.getMessage());
         }