Переглянути джерело

Merge pull request #10791 from thalesmg/fix-bridge-infinity-timeout-r50

fix(bridge): pass resource option `request_timeout = infinity` along to buffer workers (r5.0)
Zaiming (Stone) Shi 2 роки тому
батько
коміт
9363ca5846

+ 1 - 1
apps/emqx_bridge/src/emqx_bridge.erl

@@ -211,7 +211,7 @@ send_message(BridgeId, Message) ->
 
 query_opts(Config) ->
     case emqx_utils_maps:deep_get([resource_opts, request_timeout], Config, false) of
-        Timeout when is_integer(Timeout) ->
+        Timeout when is_integer(Timeout) orelse Timeout =:= infinity ->
             %% request_timeout is configured
             #{timeout => Timeout};
         _ ->

+ 1 - 1
apps/emqx_bridge/test/emqx_bridge_api_SUITE.erl

@@ -161,7 +161,7 @@ init_node(Type) ->
         primary ->
             ok = emqx_config:put(
                 [dashboard, listeners],
-                #{http => #{enable => true, bind => 18083}, proxy_header => false}
+                #{http => #{enable => true, bind => 18083, proxy_header => false}}
             ),
             ok = emqx_dashboard:start_listeners(),
             ready = emqx_dashboard_listener:regenerate_minirest_dispatch(),