don't report the topic that was asked for but that of the message

c3pb · Feb 4, 2019 · 16e944d · 16e944d
1 parent 4cb6f59
commit 16e944d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/rabbit_mqtt_processor.erl b/src/rabbit_mqtt_processor.erl
@@ -310,7 +310,7 @@ maybe_send_retained_messages(RPid, StartMsgId, #proc_state{ send_fun = SendFun }
             retain = Msg#mqtt_msg.retain
          }, variable = #mqtt_frame_publish{
             message_id = Id,
-            topic_name = S
+            topic_name = Msg#mqtt_msg.topic
          },
          payload = Msg#mqtt_msg.payload}, PState),
       NextMsgId