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

infinity

This commit is contained in:
Feng 2015-07-05 23:57:27 +08:00
parent d6ea474810
commit dcc378150d
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_session.erl
View File

@ -159,7 +159,7 @@ destroy(Session, ClientId) ->
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
-spec subscribe(pid(), [{binary(), mqtt_qos()}]) -> {ok, [mqtt_qos()]}. -spec subscribe(pid(), [{binary(), mqtt_qos()}]) -> {ok, [mqtt_qos()]}.
subscribe(Session, TopicTable) -> subscribe(Session, TopicTable) ->
gen_server:call(Session, {subscribe, TopicTable}). gen_server:call(Session, {subscribe, TopicTable}, infinity).
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
%% @doc Publish message %% @doc Publish message
@ -204,7 +204,7 @@ pubcomp(Session, PktId) ->
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
-spec unsubscribe(pid(), [binary()]) -> ok. -spec unsubscribe(pid(), [binary()]) -> ok.
unsubscribe(Session, Topics) -> unsubscribe(Session, Topics) ->
gen_server:call(Session, {unsubscribe, Topics}). gen_server:call(Session, {unsubscribe, Topics}, infinity).
%%%============================================================================= %%%=============================================================================
%%% gen_server callbacks %%% gen_server callbacks