From b4080a0adf6fcfd6c2899f06ecdf9fc289964197 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Wed, 24 Jun 2015 02:51:56 +0800 Subject: [PATCH] ts --- src/emqttd_mod_presence.erl | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/emqttd_mod_presence.erl b/src/emqttd_mod_presence.erl index fe5135c1e..83a7e9100 100644 --- a/src/emqttd_mod_presence.erl +++ b/src/emqttd_mod_presence.erl @@ -53,7 +53,7 @@ client_connected(ConnAck, #mqtt_client{clientid = ClientId, {session, Sess}, {protocol, ProtoVer}, {connack, ConnAck}, - {ts, emqttd_vm:timestamp()}]), + {ts, emqttd_util:now_to_secs()}]), Message = #mqtt_message{from = presence, qos = proplists:get_value(qos, Opts, 0), topic = topic(connected, ClientId), @@ -61,7 +61,7 @@ client_connected(ConnAck, #mqtt_client{clientid = ClientId, emqttd_pubsub:publish(Message). client_disconnected(Reason, ClientId, Opts) -> - Json = mochijson2:encode([{reason, reason(Reason)}, {ts, emqttd_vm:timestamp()}]), + Json = mochijson2:encode([{reason, reason(Reason)}, {ts, emqttd_util:now_to_secs()}]), emqttd_pubsub:publish(#mqtt_message{from = presence, qos = proplists:get_value(qos, Opts, 0), topic = topic(disconnected, ClientId), @@ -71,7 +71,6 @@ unload(_Opts) -> emqttd_broker:unhook(client_connected, {?MODULE, client_connected}), emqttd_broker:unhook(client_disconnected, {?MODULE, client_disconnected}). - topic(connected, ClientId) -> emqttd_topic:systop(list_to_binary(["clients/", ClientId, "/connected"])); topic(disconnected, ClientId) ->