anchor.diff:              {stop, normal};
   
           ok ->
  -            {next_state, connected, StateData, round(Ka*1.5)}
  +            {next_state, connected, StateData, Ka}
       end;
   
   %
  
positive.code: 
      mqtt_message_worker:provisional(request, Worker, self(), Msg),
  
      {reply, undefined, connected, StateData, round(Ka*1.5)};
  
  connected(Msg=#mqtt_msg{type='PUBREL', payload=P}, _, StateData=#session{keepalive=Ka,inflight=Inflight}) ->
      MsgID  = proplists:get_value(msgid, P),
  
negative.code:             {stop, normal};
  
          ok ->
              {next_state, connected, StateData, Ka}
      end;
  % PUBCOMP (QOS=2)
  connected({ack, MsgID, _Qos=2}, StateData=#session{transport={Callback,Transport,Socket},keepalive=Ka}) ->
  