commit
c4b01fc2ce
|
@ -2344,7 +2344,7 @@ end}.
|
||||||
{translation, "emqx.shared_subscription_strategy_per_group", fun(Conf) ->
|
{translation, "emqx.shared_subscription_strategy_per_group", fun(Conf) ->
|
||||||
Conf0 = cuttlefish_variable:filter_by_prefix("broker", Conf),
|
Conf0 = cuttlefish_variable:filter_by_prefix("broker", Conf),
|
||||||
Groups = lists:filtermap(fun({["broker", Group, "shared_subscription_strategy"], Strategy}) ->
|
Groups = lists:filtermap(fun({["broker", Group, "shared_subscription_strategy"], Strategy}) ->
|
||||||
{true, {Group, Strategy}};
|
{true, {Group, list_to_binary(Strategy)}};
|
||||||
(_) ->
|
(_) ->
|
||||||
false
|
false
|
||||||
end, Conf0),
|
end, Conf0),
|
||||||
|
|
Loading…
Reference in New Issue