diff --git a/src/transport/service_channel.erl b/src/transport/service_channel.erl index a3c0af3..cb18f8e 100644 --- a/src/transport/service_channel.erl +++ b/src/transport/service_channel.erl @@ -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 ->