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

Set default value of message expiry interval for not mqtt 5.0 message

This commit is contained in:
周子博 2018-09-13 10:31:36 +08:00 committed by Feng Lee
parent 88b3460715
commit 0c6a268539
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/emqx_protocol.erl
View File

@ -249,6 +249,13 @@ preprocess_properties(Packet = #mqtt_packet{
PState = #pstate{proto_ver = ?MQTT_PROTO_V5, topic_aliases = Aliases}) ->
{Packet, PState#pstate{topic_aliases = maps:put(AliasId, Topic, Aliases)}};
preprocess_properties(Packet = #mqtt_packet{variable = #mqtt_packet_publish{properties = #{'Message-Expiry-Interval' := _Interval}}},
PState = #pstate{proto_ver = ?MQTT_PROTO_V5}) ->
{Packet, PState};
preprocess_properties(Packet = #mqtt_packet{variable = Publish = #mqtt_packet_publish{properties = Properties}},
PState = #pstate{proto_ver = ?MQTT_PROTO_V5}) ->
{Packet#mqtt_packet{variable = Publish#mqtt_packet_publish{properties = maps:put('Message-Expiry-Interval', 0, Properties)}}, PState};
preprocess_properties(Packet, PState) ->
{Packet, PState}.