anchor.diff:  	Resp  = #mqtt_msg{type='UNSUBACK', payload=[{msgid,MsgId}]},
   
       lager:info("Ka=~p ~p", [Ka, OldTopics]),
  -    {reply, Resp, connected, StateData#session{topics=NewTopics}, round(Ka*1.5)};
  +    {reply, Resp, connected, StateData#session{topics=NewTopics}, Ka};
   
   
   connected(ping, _, StateData=#session{transport={Callback,Transport,Socket}}) ->
  
positive.code:             {stop, normal};
  
          ok ->
              {next_state, connected, StateData, round(Ka*1.5)}
      end;
  
  %
  
negative.code: 
          ok ->
              lager:debug("OK, continue"),
              {next_state, connected, StateData, Ka}
      end;
  
  % QoS 1 or 2
  