test: log on mqtt message recieved

mbta · Jan 31, 2025 · 7f1dde2 · 7f1dde2
1 parent 88d5104
commit 7f1dde2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/concentrate/producer/mqtt.ex b/lib/concentrate/producer/mqtt.ex
@@ -52,6 +52,8 @@ defmodule Concentrate.Producer.Mqtt do
 
   @impl GenStage
   def handle_info({:message, _pid, msg}, state) do
+    Logger.info("event=mqtt_message payload=#{inspect(msg.payload)}")
+
     parsed =
       state.parser.(
         decode_payload(msg.payload),