From 7f1dde21879a9c259a2a559915e5cd0f3a59d1fc Mon Sep 17 00:00:00 2001
From: Walton Hoops <me@waltonhoops.com>
Date: Fri, 31 Jan 2025 13:03:53 -0700
Subject: [PATCH] test: log on mqtt message recieved

---
 lib/concentrate/producer/mqtt.ex | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/lib/concentrate/producer/mqtt.ex b/lib/concentrate/producer/mqtt.ex
index 3cb244fb..19ec2541 100644
--- 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),