From 2d1066517fa06f86c8acb0b005960e00ef1b3796 Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Sat, 14 Nov 2015 14:44:25 +0800
Subject: [PATCH] Msg =

---
 src/emqttd_pubsub.erl | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl
index decb23d1f..63c4146d7 100644
--- a/src/emqttd_pubsub.erl
+++ b/src/emqttd_pubsub.erl
@@ -172,7 +172,7 @@ cast(Msg) ->
 %% @end
 %%------------------------------------------------------------------------------
 -spec publish(Msg :: mqtt_message()) -> ok.
-publish(#mqtt_message{from = From} = Msg) ->
+publish(Msg = #mqtt_message{from = From}) ->
     trace(publish, From, Msg),
     Msg1 = #mqtt_message{topic = Topic}
                = emqttd_broker:foldl_hooks('message.publish', [], Msg),
@@ -186,7 +186,7 @@ publish(#mqtt_message{from = From} = Msg) ->
             publish(Topic, Msg1)
      end.
 
-publish(<<"$Q/", _/binary>> = Queue, #mqtt_message{qos = Qos} = Msg) ->
+publish(Queue = <<"$Q/", _/binary>>, Msg = #mqtt_message{qos = Qos}) ->
     lists:foreach(
         fun(#mqtt_queue{qpid = QPid, qos = SubQos}) -> 
             Msg1 = if
@@ -209,7 +209,7 @@ publish(Topic, Msg) when is_binary(Topic) ->
 %% @end
 %%------------------------------------------------------------------------------
 -spec dispatch(Topic :: binary(), Msg :: mqtt_message()) -> non_neg_integer().
-dispatch(Topic, #mqtt_message{qos = Qos} = Msg ) when is_binary(Topic) ->
+dispatch(Topic, Msg = #mqtt_message{qos = Qos}) when is_binary(Topic) ->
     Subscribers = mnesia:dirty_read(subscriber, Topic),
     setstats(dropped, Subscribers =:= []),
     lists:foreach(