anchor.diff:      {value, {_, Msg}} = queue:peek(Queue),
       State1 = stream_send(Msg, State0),
       State2 = init_retransmit(State1, RetransmitCounter - 1),
  -    {next_state, StateName, State2, ?IDLE_TIMEOUT}.
  +    next_state(StateName, State2).
   
   init_retransmit(State, Counter) ->
       State#state{retransmit_timer = send_info_after(?RetransmitInterval, retransmit),
  
positive.code: 	    ?MODULE:StateName({Msg, Seq, Elements, Header}, State1);
  	_ ->
  	    %% invalid Seq, out-of-order packet, silently ignore,
  	    {next_state, StateName, State, ?IDLE_TIMEOUT}
      end.
  
  maybe_takeover(CommonName) ->
  
negative.code: 	    handle_capwap_message(Header, Msg, StateName, State#state{ctrl_stream = CtrlStreamState1});
  
  	{ok, more, CtrlStreamState1} ->
  	    next_state(StateName, State#state{ctrl_stream = CtrlStreamState1});
  
  	{error, Error} ->
  	    lager:error([{capwap_packet, decode}, {error, Error}], "Decode error ~p", [Error]),
  	    next_state(StateName, State)
      end.
  
  handle_capwap_message(Header, {Msg, 1, Seq, Elements}, StateName,
  