From dcc378150d6bd96638610c18d618ba4dd8885ba3 Mon Sep 17 00:00:00 2001 From: Feng Date: Sun, 5 Jul 2015 23:57:27 +0800 Subject: [PATCH] infinity --- src/emqttd_session.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index da2bfdf72..2971e3109 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -159,7 +159,7 @@ destroy(Session, ClientId) -> %%------------------------------------------------------------------------------ -spec subscribe(pid(), [{binary(), mqtt_qos()}]) -> {ok, [mqtt_qos()]}. subscribe(Session, TopicTable) -> - gen_server:call(Session, {subscribe, TopicTable}). + gen_server:call(Session, {subscribe, TopicTable}, infinity). %%------------------------------------------------------------------------------ %% @doc Publish message @@ -204,7 +204,7 @@ pubcomp(Session, PktId) -> %%------------------------------------------------------------------------------ -spec unsubscribe(pid(), [binary()]) -> ok. unsubscribe(Session, Topics) -> - gen_server:call(Session, {unsubscribe, Topics}). + gen_server:call(Session, {unsubscribe, Topics}, infinity). %%%============================================================================= %%% gen_server callbacks