fix
This commit is contained in:
parent
a5280cde42
commit
7768544cc1
@ -131,7 +131,7 @@ handle_request(#'ServiceRequest'{packet_id = PacketId, request = {register, #'Se
|
||||
|
||||
%% 订阅事件
|
||||
handle_request(#'ServiceRequest'{packet_id = PacketId, request = {subscribe, #'ServiceRequest.Subscribe'{topic = Topic}}},
|
||||
State = #state{ subscribed_topics = SubscribedTopics, is_registered = true}) ->
|
||||
State = #state{subscribed_topics = SubscribedTopics, is_registered = true}) ->
|
||||
|
||||
case efka_subscription:subscribe(Topic, self()) of
|
||||
ok ->
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user