|
|
@@ -222,8 +222,7 @@ create(BridgeId, Conf) ->
|
|
|
create(Type, Name, Conf) ->
|
|
|
?SLOG(info, #{msg => "create bridge", type => Type, name => Name,
|
|
|
config => Conf}),
|
|
|
- Group = maps:get(group, Conf, <<"default">>),
|
|
|
- case emqx_resource:create_local(resource_id(Type, Name), Group, emqx_bridge:resource_type(Type),
|
|
|
+ case emqx_resource:create_local(resource_id(Type, Name), <<"emqx_bridge">>, emqx_bridge:resource_type(Type),
|
|
|
parse_confs(Type, Name, Conf), #{async_create => true}) of
|
|
|
{ok, already_created} -> maybe_disable_bridge(Type, Name, Conf);
|
|
|
{ok, _} -> maybe_disable_bridge(Type, Name, Conf);
|