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

chore(emqx_channel): The pattern 'undefined' can never match the type map()

This commit is contained in:
zhanghongtong 2020-07-23 16:17:21 +08:00 committed by tigercl
parent 8f95e12534
commit fe974467d7
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/emqx_channel.erl
View File

@ -1247,13 +1247,9 @@ packing_alias(Packet = #mqtt_packet{
Channel = ?IS_MQTT_V5 = #channel{topic_aliases = TopicAliases, alias_maximum = Limits}) -> Channel = ?IS_MQTT_V5 = #channel{topic_aliases = TopicAliases, alias_maximum = Limits}) ->
case find_alias(outbound, Topic, TopicAliases) of case find_alias(outbound, Topic, TopicAliases) of
{ok, AliasId} -> {ok, AliasId} ->
NProp = case Prop of
undefined -> #{'Topic-Alias' => AliasId};
_ -> maps:merge(Prop, #{'Topic-Alias' => AliasId})
end,
NPublish = Publish#mqtt_packet_publish{ NPublish = Publish#mqtt_packet_publish{
topic_name = <<>>, topic_name = <<>>,
properties = NProp properties = maps:merge(Prop, #{'Topic-Alias' => AliasId})
}, },
{Packet#mqtt_packet{variable = NPublish}, Channel}; {Packet#mqtt_packet{variable = NPublish}, Channel};
error -> error ->
@ -1264,13 +1260,9 @@ packing_alias(Packet = #mqtt_packet{
true -> true ->
NTopicAliases = save_alias(outbound, AliasId, Topic, TopicAliases), NTopicAliases = save_alias(outbound, AliasId, Topic, TopicAliases),
NChannel = Channel#channel{topic_aliases = NTopicAliases}, NChannel = Channel#channel{topic_aliases = NTopicAliases},
NProp = case Prop of
undefined -> #{'Topic-Alias' => AliasId};
_ -> maps:merge(Prop, #{'Topic-Alias' => AliasId})
end,
NPublish = Publish#mqtt_packet_publish{ NPublish = Publish#mqtt_packet_publish{
topic_name = Topic, topic_name = Topic,
properties = NProp properties = maps:merge(Prop, #{'Topic-Alias' => AliasId})
}, },
{Packet#mqtt_packet{variable = NPublish}, NChannel}; {Packet#mqtt_packet{variable = NPublish}, NChannel};
false -> {Packet, Channel} false -> {Packet, Channel}