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

fix dispatch

This commit is contained in:
Ery Lee 2015-01-14 13:19:34 +08:00
parent eda40bf232
commit 22797172a4
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqtt/src/emqtt_client.erl
View File

@ -98,7 +98,7 @@ handle_info({stop, duplicate_id, NewPid}, State=#state{conn_name=ConnName}) ->
stop({shutdown, duplicate_id}, State); stop({shutdown, duplicate_id}, State);
%%TODO: ok?? %%TODO: ok??
handle_info({dispatch, From, Message}, #state{proto_state = ProtoState} = State) -> handle_info({dispatch, {From, Message}}, #state{proto_state = ProtoState} = State) ->
{ok, ProtoState1} = emqtt_protocol:send_message({From, Message}, ProtoState), {ok, ProtoState1} = emqtt_protocol:send_message({From, Message}, ProtoState),
{noreply, State#state{proto_state = ProtoState1}}; {noreply, State#state{proto_state = ProtoState1}};

5
apps/emqtt/src/emqtt_protocol.erl
View File

@ -222,8 +222,9 @@ puback_qos(?PUBREC) -> ?QOS_0;
puback_qos(?PUBREL) -> ?QOS_1; puback_qos(?PUBREL) -> ?QOS_1;
puback_qos(?PUBCOMP) -> ?QOS_0. puback_qos(?PUBCOMP) -> ?QOS_0.
-spec send_message(Message, State) -> {ok, NewState} when -spec send_message({From, Message}, State) -> {ok, NewState} when
Message :: {pid(), mqtt_message()}, From :: pid(),
Message :: mqtt_message(),
State :: proto_state(), State :: proto_state(),
NewState :: proto_state(). NewState :: proto_state().