From 0019fb2b49788720c00a0e38d9e326325542d2e3 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Thu, 16 Feb 2017 11:10:47 +0800 Subject: [PATCH] Change the message timestamp to 'os:timestamp()' --- src/emqttd_message.erl | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/emqttd_message.erl b/src/emqttd_message.erl index ec4a02479..4c3bea0d8 100644 --- a/src/emqttd_message.erl +++ b/src/emqttd_message.erl @@ -1,5 +1,5 @@ %%-------------------------------------------------------------------- -%% Copyright (c) 2012-2017 Feng Lee . +%% Copyright (c) 2013-2017 EMQ Enterprise, Inc. (http://emqtt.io) %% %% Licensed under the Apache License, Version 2.0 (the "License"); %% you may not use this file except in compliance with the License. @@ -15,8 +15,11 @@ %%-------------------------------------------------------------------- %% @doc MQTT Message Functions + -module(emqttd_message). +-author("Feng Lee "). + -include("emqttd.hrl"). -include("emqttd_protocol.hrl"). @@ -42,7 +45,7 @@ make(From, Qos, Topic, Payload) -> qos = ?QOS_I(Qos), topic = Topic, payload = Payload, - timestamp = emqttd_time:now_to_secs()}. + timestamp = os:timestamp()}. %% @doc Message from Packet -spec(from_packet(mqtt_packet()) -> mqtt_message()). @@ -60,7 +63,7 @@ from_packet(#mqtt_packet{header = #mqtt_packet_header{type = ?PUBLISH, dup = Dup, topic = Topic, payload = Payload, - timestamp = emqttd_time:now_to_secs()}; + timestamp = os:timestamp()}; from_packet(#mqtt_packet_connect{will_flag = false}) -> undefined; @@ -78,7 +81,7 @@ from_packet(#mqtt_packet_connect{client_id = ClientId, qos = Qos, dup = false, payload = Msg, - timestamp = emqttd_time:now_to_secs()}. + timestamp = os:timestamp()}. from_packet(ClientId, Packet) -> Msg = from_packet(Packet),