From ace9157b0fb64761951d610a54d45f5fd658b269 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Wed, 27 Aug 2025 15:19:27 +0800
Subject: [PATCH] fix channel

---
 apps/efka/src/efka_service.erl               | 4 ++--
 apps/efka/src/websocket_server/ws_server.erl | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/apps/efka/src/efka_service.erl b/apps/efka/src/efka_service.erl
index 7a5c0b2..542fe28 100644
--- a/apps/efka/src/efka_service.erl
+++ b/apps/efka/src/efka_service.erl
@@ -169,7 +169,7 @@ handle_cast({send_event, EventType, Params}, State = #state{service_id = Service
 handle_cast({push_config, Ref, ReceiverPid, ConfigJson}, State = #state{channel_pid = ChannelPid, service_id = ServiceId, inflight = Inflight, callbacks = Callbacks}) ->
     case is_pid(ChannelPid) andalso is_process_alive(ChannelPid) of
         true ->
-            efka_tcp_channel:push_config(ChannelPid, Ref, self(), ConfigJson),
+            tcp_channel:push_config(ChannelPid, Ref, self(), ConfigJson),
             %% 设置成功，需要更新微服务的配置
             CB = fun() -> service_model:set_config(ServiceId, ConfigJson) end,
             {noreply, State#state{inflight = maps:put(Ref, ReceiverPid, Inflight), callbacks = maps:put(Ref, CB, Callbacks)}};
@@ -182,7 +182,7 @@ handle_cast({push_config, Ref, ReceiverPid, ConfigJson}, State = #state{channel_
 handle_cast({invoke, Ref, ReceiverPid, Payload}, State = #state{channel_pid = ChannelPid, inflight = Inflight}) ->
     case is_pid(ChannelPid) andalso is_process_alive(ChannelPid) of
         true ->
-            efka_tcp_channel:invoke(ChannelPid, Ref, self(), Payload),
+            tcp_channel:invoke(ChannelPid, Ref, self(), Payload),
             {noreply, State#state{inflight = maps:put(Ref, ReceiverPid, Inflight)}};
         false ->
             ReceiverPid ! {service_reply, Ref, {error, <<"channel is not alive">>}},
diff --git a/apps/efka/src/websocket_server/ws_server.erl b/apps/efka/src/websocket_server/ws_server.erl
index c7edfe7..3205907 100644
--- a/apps/efka/src/websocket_server/ws_server.erl
+++ b/apps/efka/src/websocket_server/ws_server.erl
@@ -13,7 +13,7 @@
 -export([start_server/0]).
 
 start_server() ->
-    {ok, Props} = application:get_env(iot, ws_server),
+    {ok, Props} = application:get_env(efka, ws_server),
     Acceptors = proplists:get_value(acceptors, Props, 50),
     MaxConnections = proplists:get_value(max_connections, Props, 10240),
     Backlog = proplists:get_value(backlog, Props, 1024),