diff options
| author | Badlop <badlop@process-one.net> | 2022-01-11 13:53:32 +0100 |
|---|---|---|
| committer | Badlop <badlop@process-one.net> | 2022-01-25 13:20:31 +0100 |
| commit | 1b192987d20cc5f572c7324966a0dde033e606d4 (patch) | |
| tree | b577da1393e666db21a09042a9e9a3469fcd4607 | |
| parent | Pass property name as expected in mqtt_codec (fixes login using MQTT 5) (diff) | |
Support MQTT subscriptions spread over the cluster (#3750)
| -rw-r--r-- | src/mod_mqtt_mnesia.erl | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/src/mod_mqtt_mnesia.erl b/src/mod_mqtt_mnesia.erl index 20c533ede..6c230a8f6 100644 --- a/src/mod_mqtt_mnesia.erl +++ b/src/mod_mqtt_mnesia.erl @@ -22,7 +22,7 @@ -export([init/2, publish/6, delete_published/2, lookup_published/2]). -export([list_topics/1, use_cache/1]). -export([init/0]). --export([subscribe/4, unsubscribe/2, find_subscriber/2]). +-export([subscribe/4, unsubscribe/2, find_subscriber/2, mqtree_match/1]). -export([open_session/1, close_session/1, lookup_session/1, get_sessions/2]). -include("logger.hrl"). @@ -249,9 +249,16 @@ unsubscribe({U, S, R} = USR, Topic) -> Reason, [jid:encode(USR), Topic]) end. -find_subscriber(S, Topic) when is_binary(Topic) -> +mqtree_match(Topic) -> Tree = mqtree:whereis(mqtt_sub_index), - case mqtree:match(Tree, Topic) of + mqtree:match(Tree, Topic). + +mqtree_multi_match(Topic) -> + {Res, []} = ejabberd_cluster:multicall(?MODULE, mqtree_match, [Topic]), + lists:umerge(Res). + +find_subscriber(S, Topic) when is_binary(Topic) -> + case mqtree_multi_match(Topic) of [Filter|Filters] -> find_subscriber(S, {Filters, {Filter, S, '_', '_'}}); [] -> |