anchor.diff:      lager:error("Unexpected Msg: ~p", [Msg]),
       {noreply, State}.
   
  -handle_info({'DOWN', MRef, process, DownPid, _Reason}, State = #state{monitors = MonDict}) ->
  -    case dict:find(MRef, MonDict) of
  +handle_info({'DOWN', MRef, process, DownPid, _Reason}, State) ->
  +    case dict:find(MRef, State#state.monitors) of
           {ok, {ClientId, DownPid}} ->
               case lookup_proc(ClientId) of
                   DownPid ->
  
positive.code: handle_cast({register, Client = #mqtt_client{client_id  = ClientId,
                                               client_pid = Pid}}, State) ->
      case lookup_proc(ClientId) of
          Pid  ->
              {noreply, State};
          _None ->
              ets:insert(mqtt_client, Client),
              {noreply, setstats(monitor_client(ClientId, Pid, State))}
  	end;
  
negative.code:         Pid ->
              ets:delete(mqtt_client, ClientId),
              {noreply, setstats(State)};
          _ ->
              {noreply, State}
      end;
  
  