diff --git a/apps/state_mediator/lib/state_mediator/mqtt_mediator/handler.ex b/apps/state_mediator/lib/state_mediator/mqtt_mediator/handler.ex index 28331950a..572fc3973 100644 --- a/apps/state_mediator/lib/state_mediator/mqtt_mediator/handler.ex +++ b/apps/state_mediator/lib/state_mediator/mqtt_mediator/handler.ex @@ -27,6 +27,8 @@ defmodule StateMediator.MqttMediator.Handler do @impl EmqttFailover.ConnectionHandler def handle_message(message, state) do + Logger.info("event=mqtt_message payload=#{inspect(message)}") + debug_time("#{state.module} new state", fn -> state.module.new_state(message.payload, state.timeout) end)