anchor.diff:                      lager:info("closing socket"),
                       %Transport:close(Socket),
                       stop
  -            end
  +            end;
  +
  +
  +        _CatchAll ->
  +            lager:error("MQTT Msg unknown decoding error: ~p", [_CatchAll])
       end.
   
   answer(#mqtt_msg{type='CONNECT'}) ->
  
positive.code:             lager:notice("Packet is too short, missing ~p bytes", [Extend]),
              {extend, Extend, Raw};
  
          {error, Reason} ->
              lager:error("closing connection. Reason: ~p", [Reason]),
              Transport:close(Socket),
              stop;
  
negative.code:             case mqtt_session:handle(Session, Msg) of
                  {ok, Resp=#mqtt_msg{}} ->
                      lager:info("sending resp ~p", [Resp]),
                      Res = Transport:send(Socket, mqtt_msg:encode(Resp)),
                      lager:debug("msg send result= ~p", [Res]),
                      route(Socket, Transport, Session, Rest);
  
                  {ok, undefined}  ->
  