diff --git a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq.erl b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq.erl index faac69095..22514dc5c 100644 --- a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq.erl +++ b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq.erl @@ -64,8 +64,6 @@ conn_bridge_example_values(post) -> conn_bridge_example_values(put) -> conn_bridge_example_values(post). -%% TODO fix these examples - connector_examples(Method) -> [ #{ @@ -226,8 +224,6 @@ desc("config") -> ?DESC("desc_config"); desc(Method) when Method =:= "get"; Method =:= "put"; Method =:= "post" -> ["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(rocketmq_action) -> 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 baa895a8a..c9a7ce177 100644 --- a/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl +++ b/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl @@ -110,11 +110,6 @@ on_start( client_id => ClientId, acl_info => ACLInfo, installed_channels => #{} - % topic => Topic, - % topic_tokens => TopicTks, - % sync_timeout => SyncTimeout, - % templates => Templates, - % producers_opts => ProducerOpts }, ok = emqx_resource:allocate_resource(InstanceId, client_id, ClientId),