anchor.diff:              case mqtt_session:handle(Session, Msg) of
                   {ok, Resp=#mqtt_msg{}} ->
                       lager:info("sending resp ~p", [Resp]),
  -                    Transport:send(Socket, mqtt_msg:encode(Resp)),
  +                    Res = Transport:send(Socket, mqtt_msg:encode(Resp)),
  +                    lager:debug("msg send result= ~p", [Res]),
                       route(Socket, Transport, Session, Rest);
   
                   {ok, undefined}  ->
  
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:                     lager:info("closing socket"),
                      %Transport:close(Socket),
                      stop
              end;
  
  
          _CatchAll ->
              lager:error("MQTT Msg unknown decoding error: ~p", [_CatchAll])
      end.
  
  answer(#mqtt_msg{type='CONNECT'}) ->
  