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.