yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: cleanups due to problems found by @thalesmg

This commit is contained in:
Kjell Winblad 2024-02-12 10:16:17 +01:00
parent 511d1f732a
commit 976099f5fb
2 changed files with 0 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq.erl
View File

@ -64,8 +64,6 @@ conn_bridge_example_values(post) ->
conn_bridge_example_values(put) -> conn_bridge_example_values(put) ->
conn_bridge_example_values(post). conn_bridge_example_values(post).
%% TODO fix these examples
connector_examples(Method) -> connector_examples(Method) ->
[ [
#{ #{
@ -226,8 +224,6 @@ desc("config") ->
?DESC("desc_config"); ?DESC("desc_config");
desc(Method) when Method =:= "get"; Method =:= "put"; Method =:= "post" -> desc(Method) when Method =:= "get"; Method =:= "put"; Method =:= "post" ->
["Configuration for RocketMQ using `", string:to_upper(Method), "` method."]; ["Configuration for RocketMQ using `", string:to_upper(Method), "` method."];
desc("creation_opts") ->
?DESC(emqx_resource_schema, "creation_opts");
desc("config_connector") -> desc("config_connector") ->
?DESC("config_connector"); ?DESC("config_connector");
desc(rocketmq_action) -> desc(rocketmq_action) ->

5
apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl
View File

@ -110,11 +110,6 @@ on_start(
client_id => ClientId, client_id => ClientId,
acl_info => ACLInfo, acl_info => ACLInfo,
installed_channels => #{} installed_channels => #{}
% topic => Topic,
% topic_tokens => TopicTks,
% sync_timeout => SyncTimeout,
% templates => Templates,
% producers_opts => ProducerOpts
}, },
ok = emqx_resource:allocate_resource(InstanceId, client_id, ClientId), ok = emqx_resource:allocate_resource(InstanceId, client_id, ClientId),