Procházet zdrojové kódy

fix(delayed): default username when get delayed message form `/publish` api.

JimMoen před 4 roky
rodič
revize
5baf427b75
1 změnil soubory, kde provedl 2 přidání a 2 odebrání
  1. 2 2
      apps/emqx_modules/src/emqx_delayed.erl

+ 2 - 2
apps/emqx_modules/src/emqx_delayed.erl

@@ -135,7 +135,7 @@ format_delayed(Delayed) ->
 format_delayed(#delayed_message{key = {ExpectTimeStamp, Id}, delayed = Delayed,
             msg = #message{topic = Topic,
                            from = From,
-                           headers = #{username := Username},
+                           headers = Headers,
                            qos = Qos,
                            timestamp = PublishTimeStamp,
                            payload = Payload}}, WithPayload) ->
@@ -151,7 +151,7 @@ format_delayed(#delayed_message{key = {ExpectTimeStamp, Id}, delayed = Delayed,
         topic => Topic,
         qos => Qos,
         from_clientid => From,
-        from_username => Username
+        from_username => maps:get(username, Headers, undefined)
     },
     case WithPayload of
         true ->