Przeglądaj źródła

Merge pull request #12374 from thalesmg/fix-mqtt-batching-r55-20240123

fix(mqtt_action): use overridden `resource_opts`
Thales Macedo Garitezi 2 lat temu
rodzic
commit
346e5fa55b

+ 6 - 4
apps/emqx_bridge_mqtt/src/emqx_bridge_mqtt_pubsub_schema.erl

@@ -48,13 +48,14 @@ fields(action) ->
         )};
         )};
 fields("mqtt_publisher_action") ->
 fields("mqtt_publisher_action") ->
     emqx_bridge_v2_schema:make_producer_action_schema(
     emqx_bridge_v2_schema:make_producer_action_schema(
-        hoconsc:mk(
-            hoconsc:ref(?MODULE, action_parameters),
+        mk(
+            ref(?MODULE, action_parameters),
             #{
             #{
                 required => true,
                 required => true,
                 desc => ?DESC("action_parameters")
                 desc => ?DESC("action_parameters")
             }
             }
-        )
+        ),
+        #{resource_opts_ref => ref(?MODULE, action_resource_opts)}
     );
     );
 fields(action_parameters) ->
 fields(action_parameters) ->
     [
     [
@@ -86,7 +87,8 @@ fields("mqtt_subscriber_source") ->
                 required => true,
                 required => true,
                 desc => ?DESC("source_parameters")
                 desc => ?DESC("source_parameters")
             }
             }
-        )
+        ),
+        #{resource_opts_ref => ref(?MODULE, source_resource_opts)}
     );
     );
 fields(ingress_parameters) ->
 fields(ingress_parameters) ->
     [
     [