diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl
index eafe44b..4d6ce26 100644
--- a/apps/efka/src/efka_agent.erl
+++ b/apps/efka/src/efka_agent.erl
@@ -127,34 +127,28 @@ handle_info({connect_reply, Reply}, State = #state{status = ?STATE_CONNECTING, t
     end;
 
 handle_info({auth_reply, {ok, ReplyBin}}, State = #state{status = ?STATE_AUTH, transport_pid = TransportPid}) ->
-    try message_pb:decode_msg(ReplyBin, auth_reply) of
-        #auth_reply{code = Code, message = Message, repository_url = RepositoryUrl} ->
-            case Code of
-                0 ->
-                    lager:debug("[efka_agent] auth failed, message: ~p, repository_url: ~p", [Message, RepositoryUrl]),
-                    {noreply, State#state{status = ?STATE_ACTIVATED}};
-                1 ->
-                    %% 主机在后台的授权未通过；此时agent不能推送数据给云端服务器，但是云端服务器可以推送命令给agent
-                    %% socket的连接状态需要维持
-                    lager:debug("[efka_agent] auth denied, message: ~p", [Message]),
-                    {noreply, State#state{status = ?STATE_RESTRICTED}};
-                2 ->
-                    % 其他类型的错误，需要间隔时间重试
-                    efka_logger:debug("[efka_agent] auth failed, message: ~p", [Message]),
-                    efka_transport:stop(TransportPid),
-                    {noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}};
-                _ ->
-                    % 其他类型的错误，需要间隔时间重试
-                    lager:debug("[efka_agent] auth failed, invalid message"),
-                    efka_transport:stop(TransportPid),
-                    {noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}}
-            end
-    catch _:Reason ->
-        % 其他类型的错误，需要间隔时间重试
-        lager:debug("[efka_agent] auth decode bin get error: ~p", [Reason]),
-        efka_transport:stop(TransportPid),
-        {noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}}
+    #auth_reply{code = Code, message = Message, repository_url = RepositoryUrl} = message_pb:decode_msg(ReplyBin, auth_reply),
+    case Code of
+        0 ->
+            lager:debug("[efka_agent] auth failed, message: ~p, repository_url: ~p", [Message, RepositoryUrl]),
+            {noreply, State#state{status = ?STATE_ACTIVATED}};
+        1 ->
+            %% 主机在后台的授权未通过；此时agent不能推送数据给云端服务器，但是云端服务器可以推送命令给agent
+            %% socket的连接状态需要维持
+            lager:debug("[efka_agent] auth denied, message: ~p", [Message]),
+            {noreply, State#state{status = ?STATE_RESTRICTED}};
+        2 ->
+            % 其他类型的错误，需要间隔时间重试
+            efka_logger:debug("[efka_agent] auth failed, message: ~p", [Message]),
+            efka_transport:stop(TransportPid),
+            {noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}};
+        _ ->
+            % 其他类型的错误，需要间隔时间重试
+            lager:debug("[efka_agent] auth failed, invalid message"),
+            efka_transport:stop(TransportPid),
+            {noreply, State#state{transport_pid = undefined, status = ?STATE_DENIED}}
     end;
+
 handle_info({auth_reply, {error, Reason}}, State = #state{transport_pid = TransportPid, status = ?STATE_AUTH}) ->
     lager:debug("[efka_agent] auth_request failed, error: ~p", [Reason]),
     efka_transport:stop(TransportPid),