From 5921ed3d2eb270677c9891cc3b69c43bf58f521c Mon Sep 17 00:00:00 2001 From: firest Date: Mon, 5 Jun 2023 10:43:28 +0800 Subject: [PATCH] fix(rocketmq): improve function name --- .../src/emqx_bridge_rocketmq_connector.erl | 2 +- apps/emqx_resource/src/emqx_resource.erl | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl index a7823c5ea..254d6b39a 100644 --- a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl +++ b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl @@ -145,7 +145,7 @@ on_stop(InstanceId, _State) -> ({_, _Topic, Producer}) -> _ = rocketmq:stop_and_delete_supervised_producers(Producer) end, - emqx_resource:lookup_allocated_resources(InstanceId) + emqx_resource:get_allocated_resources_list(InstanceId) ). on_query(InstanceId, Query, State) -> diff --git a/apps/emqx_resource/src/emqx_resource.erl b/apps/emqx_resource/src/emqx_resource.erl index 5bc83e1ac..0dbc3067f 100644 --- a/apps/emqx_resource/src/emqx_resource.erl +++ b/apps/emqx_resource/src/emqx_resource.erl @@ -85,7 +85,7 @@ allocate_resource/3, has_allocated_resources/1, get_allocated_resources/1, - lookup_allocated_resources/1, + get_allocated_resources_list/1, forget_allocated_resources/1 ]). @@ -520,8 +520,8 @@ get_allocated_resources(InstanceId) -> Objects = ets:lookup(?RESOURCE_ALLOCATION_TAB, InstanceId), maps:from_list([{K, V} || {_InstanceId, K, V} <- Objects]). --spec lookup_allocated_resources(resource_id()) -> list(tuple()). -lookup_allocated_resources(InstanceId) -> +-spec get_allocated_resources_list(resource_id()) -> list(tuple()). +get_allocated_resources_list(InstanceId) -> ets:lookup(?RESOURCE_ALLOCATION_TAB, InstanceId). -spec forget_allocated_resources(resource_id()) -> ok.