diff --git a/src/transport/efka_client.erl b/src/transport/efka_client.erl index 9495675..0e9f1c5 100644 --- a/src/transport/efka_client.erl +++ b/src/transport/efka_client.erl @@ -168,12 +168,14 @@ handle_event(info, {ssl, Socket, PacketBin}, _, State = #state{socket = Socket}) schedule_reconnect(), {next_state, ?STATE_DISCONNECTED, State#state{socket = undefined, auth_ref = undefined}} end; -handle_event(info, {ssl_error, Socket, Reason}, _, State = #state{socket = Socket}) -> +handle_event(info, {ssl_error, Socket, Reason}, _, State = #state{}) -> logger:debug("[efka_client] ssl error: ~p", [Reason]), disconnect(Socket), schedule_reconnect(), {next_state, ?STATE_DISCONNECTED, State#state{socket = undefined, auth_ref = undefined}}; -handle_event(info, {ssl_closed, Socket}, _, State = #state{socket = Socket}) -> +handle_event(info, {ssl_closed, Socket}, _, State = #state{}) -> + logger:debug("[efka_client] ssl closed"), + disconnect(Socket), schedule_reconnect(), {next_state, ?STATE_DISCONNECTED, State#state{socket = undefined, auth_ref = undefined}};