Feng 10 gadi atpakaļ
vecāks
revīzija
e25856e9a1
1 mainītis faili ar 1 papildinājumiem un 1 dzēšanām
  1. 1 1
      src/emqttd_session.erl

+ 1 - 1
src/emqttd_session.erl

@@ -174,7 +174,7 @@ destroy(SessPid, ClientId) ->
 %%------------------------------------------------------------------------------
 %%------------------------------------------------------------------------------
 -spec subscribe(pid(), [{binary(), mqtt_qos()}]) -> ok.
 -spec subscribe(pid(), [{binary(), mqtt_qos()}]) -> ok.
 subscribe(SessPid, TopicTable) ->
 subscribe(SessPid, TopicTable) ->
-    subscribe(SessPid, TopicTable, fun(_) -> ok end).
+    gen_server2:cast(SessPid, {subscribe, TopicTable, fun(_) -> ok end}).
 
 
 -spec subscribe(pid(), mqtt_packet_id(), [{binary(), mqtt_qos()}]) -> ok.
 -spec subscribe(pid(), mqtt_packet_id(), [{binary(), mqtt_qos()}]) -> ok.
 subscribe(SessPid, PacketId, TopicTable) ->
 subscribe(SessPid, PacketId, TopicTable) ->