diff options
Diffstat (limited to 'src/mod_pubsub/mod_pubsub.erl')
| -rw-r--r-- | src/mod_pubsub/mod_pubsub.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mod_pubsub/mod_pubsub.erl b/src/mod_pubsub/mod_pubsub.erl index fd0c6ee6e..a275b0104 100644 --- a/src/mod_pubsub/mod_pubsub.erl +++ b/src/mod_pubsub/mod_pubsub.erl @@ -1509,7 +1509,7 @@ send_authorization_request(#pubsub_node{owners = Owners, nodeid = {Host, Node}}, {"label", translate:translate(Lang, "Allow this Jabber ID to subscribe to this pubsub node?")}], [{xmlelement, "value", [], [{xmlcdata, "false"}]}]}]}]}, lists:foreach(fun(Owner) -> - ejabberd_router ! {route, service_jid(Host), jlib:make_jid(Owner), Stanza} + ejabberd_router:route(service_jid(Host), jlib:make_jid(Owner), Stanza) end, Owners). find_authorization_response(Packet) -> @@ -1559,7 +1559,7 @@ send_authorization_approval(Host, JID, SNode, Subscription) -> [{xmlelement, "subscription", [{"jid", jlib:jid_to_string(JID)}|nodeAttr(SNode)] ++ SubAttrs, []}]), - ejabberd_router ! {route, service_jid(Host), JID, Stanza}. + ejabberd_router:route(service_jid(Host), JID, Stanza). handle_authorization_response(Host, From, To, Packet, XFields) -> case {lists:keysearch("pubsub#node", 1, XFields), @@ -2330,7 +2330,7 @@ send_items(Host, Node, NodeId, Type, LJID, last) -> Stanza = event_stanza_with_delay( [{xmlelement, "items", nodeAttr(Node), itemsEls([LastItem])}], ModifNow, ModifLjid), - ejabberd_router ! {route, service_jid(Host), jlib:make_jid(LJID), Stanza} + ejabberd_router:route(service_jid(Host), jlib:make_jid(LJID), Stanza) end; send_items(Host, Node, NodeId, Type, LJID, Number) -> ToSend = case node_action(Host, Type, get_items, [NodeId, LJID]) of @@ -2355,7 +2355,7 @@ send_items(Host, Node, NodeId, Type, LJID, Number) -> [{xmlelement, "items", nodeAttr(Node), itemsEls(ToSend)}]) end, - ejabberd_router ! {route, service_jid(Host), jlib:make_jid(LJID), Stanza}. + ejabberd_router:route(service_jid(Host), jlib:make_jid(LJID), Stanza). %% @spec (Host, JID, Plugins) -> {error, Reason} | {result, Response} %% Host = host() @@ -2757,7 +2757,7 @@ set_subscriptions(Host, Node, From, EntitiesEls) -> [{"jid", jlib:jid_to_string(JID)}, %{"subid", SubId}, {"subscription", subscription_to_string(Sub)} | nodeAttr(Node)], []}]}]}, - ejabberd_router ! {route, service_jid(Host), jlib:make_jid(JID), Stanza} + ejabberd_router:route(service_jid(Host), jlib:make_jid(JID), Stanza) end, Action = fun(#pubsub_node{owners = Owners, type = Type, id = NodeId}) -> case lists:member(Owner, Owners) of @@ -3105,7 +3105,7 @@ broadcast_stanza(Host, Node, _NodeId, _Type, NodeOptions, SubsByDepth, NotifyTyp end, SHIMStanza = add_headers(Stanza, collection_shim(Node, Nodes)), lists:foreach(fun(To) -> - ejabberd_router ! {route, From, jlib:make_jid(To), SHIMStanza} + ejabberd_router:route(From, jlib:make_jid(To), SHIMStanza) end, LJIDs) end, NodesByJID), %% Handles implicit presence subscriptions @@ -3139,7 +3139,7 @@ broadcast_stanza(Host, Node, _NodeId, _Type, NodeOptions, SubsByDepth, NotifyTyp end end, [], user_resources(U, S)), lists:foreach(fun(To) -> - ejabberd_router ! {route, Sender, jlib:make_jid(To), Stanza} + ejabberd_router:route(Sender, jlib:make_jid(To), Stanza) end, LJIDs) end) end, Contacts); |