diff --git a/apps/emqx_bridge/src/emqx_bridge_api.erl b/apps/emqx_bridge/src/emqx_bridge_api.erl index f53503b86..e0b921a1c 100644 --- a/apps/emqx_bridge/src/emqx_bridge_api.erl +++ b/apps/emqx_bridge/src/emqx_bridge_api.erl @@ -1132,15 +1132,14 @@ maybe_unwrap({error, not_implemented}) -> maybe_unwrap(RpcMulticallResult) -> emqx_rpc:unwrap_erpc(RpcMulticallResult). -supported_versions(start_bridge_to_node) -> bpapi_version_range(2, latest); -supported_versions(start_bridges_to_all_nodes) -> bpapi_version_range(2, latest); -supported_versions(get_metrics_from_all_nodes) -> bpapi_version_range(4, latest); -supported_versions(_Call) -> bpapi_version_range(1, latest). +supported_versions(start_bridge_to_node) -> bpapi_version_range(2, 6); +supported_versions(start_bridges_to_all_nodes) -> bpapi_version_range(2, 6); +supported_versions(get_metrics_from_all_nodes) -> bpapi_version_range(4, 6); +supported_versions(_Call) -> bpapi_version_range(1, 6). %% [From, To] (inclusive on both ends) -bpapi_version_range(From, latest) -> - ThisNodeVsn = emqx_bpapi:supported_version(node(), ?BPAPI_NAME), - lists:seq(From, ThisNodeVsn). +bpapi_version_range(From, To) -> + lists:seq(From, To). redact(Term) -> emqx_utils:redact(Term). diff --git a/apps/emqx_bridge/src/emqx_bridge_v2_api.erl b/apps/emqx_bridge/src/emqx_bridge_v2_api.erl index e8a500e85..95471ae5b 100644 --- a/apps/emqx_bridge/src/emqx_bridge_v2_api.erl +++ b/apps/emqx_bridge/src/emqx_bridge_v2_api.erl @@ -1052,12 +1052,11 @@ do_bpapi_call_vsn(Version, Call, Args) -> is_supported_version(Version, Call) -> lists:member(Version, supported_versions(Call)). -supported_versions(_Call) -> bpapi_version_range(6, latest). +supported_versions(_Call) -> bpapi_version_range(6, 6). %% [From, To] (inclusive on both ends) -bpapi_version_range(From, latest) -> - ThisNodeVsn = emqx_bpapi:supported_version(node(), ?BPAPI_NAME), - lists:seq(From, ThisNodeVsn). +bpapi_version_range(From, To) -> + lists:seq(From, To). maybe_unwrap({error, not_implemented}) -> {error, not_implemented};