diff --git a/apps/emqx_modules/src/proto/emqx_delayed_proto_v1.erl b/apps/emqx_modules/src/proto/emqx_delayed_proto_v1.erl index 4c4a55dc4..4a482cfab 100644 --- a/apps/emqx_modules/src/proto/emqx_delayed_proto_v1.erl +++ b/apps/emqx_modules/src/proto/emqx_delayed_proto_v1.erl @@ -18,17 +18,19 @@ -behaviour(emqx_bpapi). --export([ introduced_in/0 - , get_delayed_message/2 - , delete_delayed_message/2 - ]). +-export([ + introduced_in/0, + get_delayed_message/2, + delete_delayed_message/2 +]). -include_lib("emqx/include/bpapi.hrl"). introduced_in() -> "5.0.0". --spec get_delayed_message(node(), binary()) -> emqx_delayed:with_id_return(map()) | emqx_rpc:badrpc(). +-spec get_delayed_message(node(), binary()) -> + emqx_delayed:with_id_return(map()) | emqx_rpc:badrpc(). get_delayed_message(Node, HexId) -> rpc:call(Node, emqx_delayed, get_delayed_message, [HexId]). diff --git a/apps/emqx_modules/src/proto/emqx_telemetry_proto_v1.erl b/apps/emqx_modules/src/proto/emqx_telemetry_proto_v1.erl index 81aa07b65..4103c2f85 100644 --- a/apps/emqx_modules/src/proto/emqx_telemetry_proto_v1.erl +++ b/apps/emqx_modules/src/proto/emqx_telemetry_proto_v1.erl @@ -18,12 +18,13 @@ -behaviour(emqx_bpapi). --export([ introduced_in/0 +-export([ + introduced_in/0, - , get_uuid/1 - , enable_telemetry/1 - , disable_telemetry/1 - ]). + get_uuid/1, + enable_telemetry/1, + disable_telemetry/1 +]). -include_lib("emqx/include/bpapi.hrl"). diff --git a/apps/emqx_modules/src/proto/emqx_topic_metrics_proto_v1.erl b/apps/emqx_modules/src/proto/emqx_topic_metrics_proto_v1.erl index 643cb4c3c..55cd33032 100644 --- a/apps/emqx_modules/src/proto/emqx_topic_metrics_proto_v1.erl +++ b/apps/emqx_modules/src/proto/emqx_topic_metrics_proto_v1.erl @@ -18,13 +18,14 @@ -behaviour(emqx_bpapi). --export([ introduced_in/0 +-export([ + introduced_in/0, - , metrics/1 - , metrics/2 - , reset/1 - , reset/2 - ]). + metrics/1, + metrics/2, + reset/1, + reset/2 +]). -include_lib("emqx/include/bpapi.hrl").