yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

emqttd:publish/1

This commit is contained in:
Feng 2016-03-08 13:26:46 +08:00
parent 26655f1ee3
commit 16d488adca
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqttd_mod_presence.erl
View File

@ -52,7 +52,7 @@ client_connected(ConnAck, #mqtt_client{client_id = ClientId,
proplists:get_value(qos, Opts, 0),
topic(connected, ClientId),
iolist_to_binary(Json)),
emqttd_pubsub:publish(Msg).
emqttd:publish(Msg).
client_disconnected(Reason, ClientId, Opts) ->
Json = mochijson2:encode([{clientid, ClientId},
@ -62,7 +62,7 @@ client_disconnected(Reason, ClientId, Opts) ->
proplists:get_value(qos, Opts, 0),
topic(disconnected, ClientId),
iolist_to_binary(Json)),
emqttd_pubsub:publish(Msg).
emqttd:publish(Msg).
unload(_Opts) ->
emqttd_broker:unhook('client.connected', {?MODULE, client_connected}),

2
src/emqttd_protocol.erl
View File

@ -302,7 +302,7 @@ maybe_set_clientid(State) ->
send_willmsg(_ClientId, undefined) ->
ignore;
send_willmsg(ClientId, WillMsg) ->
emqttd_pubsub:publish(WillMsg#mqtt_message{from = ClientId}).
emqttd:publish(WillMsg#mqtt_message{from = ClientId}).
start_keepalive(0) -> ignore;