diff --git a/src/transport/efka_client.erl b/src/transport/efka_client.erl index 5327d57..e587fe1 100644 --- a/src/transport/efka_client.erl +++ b/src/transport/efka_client.erl @@ -216,6 +216,10 @@ handle_event(internal, {request, PacketId, {container_request, Request}}, ?STATE logger:notice("[efka_client] get a invalid request: ~p, agent restricted", [Request]), handle_container_reply(Socket, PacketId, {error, <<"agent restricted">>}), {keep_state, State}; +handle_event(internal, {request, PacketId, {container_request, Request}}, _StateName, State = #state{socket = Socket}) -> + logger:notice("[efka_client] get a invalid request: ~p, agent restricted", [Request]), + handle_container_reply(Socket, PacketId, {error, <<"agent invalid">>}), + {keep_state, State}; %% 处理response handle_event(internal, {response, AuthPacketId, {auth_response, {ok, Message}}},