diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/playerUpdates.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/playerUpdates.kt index eb51ecf..2a51006 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/playerUpdates.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/playerUpdates.kt @@ -19,7 +19,7 @@ fun playerUpdatesToWsServer( consumedAs("stream-player-updates-for-ws-server", jsonMapper.serde(), jsonMapper.serde()) ) .foreach { _, value -> -// println("sending ${value.packetType} packet to websocket") + println("sending ${value.packetType} packet to websocket") websocketServer.sendMessage(jsonMapper.encodeToString(value)) } }