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

subscribe

This commit is contained in:
Feng 2015-11-30 23:35:46 +08:00
parent 0b1540f1db
commit d397ae7da1
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqttd_pubsub.erl
View File

@ -239,8 +239,8 @@ init([Id, _Opts]) ->
prioritise_call(Msg, _From, _Len, _State) -> prioritise_call(Msg, _From, _Len, _State) ->
case Msg of case Msg of
{subscriber, _, _} -> 1; {subscribe, _, _} -> 1;
_ -> 0 _ -> 0
end. end.
prioritise_cast(Msg, _Len, _State) -> prioritise_cast(Msg, _Len, _State) ->