anchor.diff:  handle_info({keepalive, check}, State = #state{peername = Peername, keepalive = KeepAlive}) ->
       case emqttd_keepalive:check(KeepAlive) of
       {ok, KeepAlive1} ->
  -        lager:debug("Client ~s: Keepalive Resumed", [emqttd_net:format(Peername)]),
           noreply(State#state{keepalive = KeepAlive1});
       {error, timeout} ->
  -        lager:debug("Client ~s: Keepalive Timeout!", [emqttd_net:format(Peername)]),
  +        lager:debug("Client(~s): Keepalive Timeout!", [emqttd_net:format(Peername)]),
           stop({shutdown, keepalive_timeout}, State#state{keepalive = undefined});
       {error, Error} ->
  -        lager:debug("Client ~s: Keepalive Error: ~p!", [emqttd_net:format(Peername), Error]),
  +        lager:debug("Client(~s): Keepalive Error: ~p!", [emqttd_net:format(Peername), Error]),
           stop({shutdown, keepalive_error}, State#state{keepalive = undefined})
       end;
   
  
positive.code:     with_session(fun(SessPid) -> emqttd_session:unsubscribe(SessPid, Topics) end, State);
  
  handle_cast(Msg, State = #state{peername = Peername}) ->
      lager:error("Client ~s: unexpected msg - ~p",[emqttd_net:format(Peername), Msg]),
      {noreply, State}.
  
  handle_info(timeout, State) ->
  
negative.code:             stop(Reason, State#state{proto_state = ProtoState1})
          end;
      {error, Error} ->
          lager:error("MQTT framing error ~p for connection ~p", [Error, ConnStr]),
          stop({shutdown, Error}, State)
      end.
  
  network_error(Reason, State = #state{peername = Peername}) ->
      lager:warning("Client(~s): MQTT detected network error '~p'",
                      [emqttd_net:format(Peername), Reason]),
      stop({shutdown, conn_closed}, State).
  
  