anchor.diff:      ok.
   
   code_change(_OldVsn, State, _Extra) ->
  -    State.+    State.
  
positive.code:                 #state{control_ctag = ControlCTag} = State) ->
      {stop, normal, State};
  
  %% Continue working if we stop consuming from a Detour Queue
  handle_info(#'basic.cancel_ok'{}, State) ->
      {noreply, State};
  
  
negative.code: %% amqp_consumer:start_demo(<<"control">>, <<"my.rkey">>).
  start_demo(Exchange, RKey) ->
    {ok, Connection} = amqp_connection:start(network, #amqp_params{}),
    ?MODULE:start([Connection, Exchange, RKey]).
  
  start([Connection, ControlExchange, ControlRKey]) ->
      gen_server:start(?MODULE, [Connection, ControlExchange, ControlRKey], []).
  
  start_link([Connection, ControlExchange, ControlRKey]) ->
      gen_server:start_link(?MODULE, [Connection, ControlExchange, ControlRKey], []).
  
  stop(Pid) ->
      gen_server:call(Pid, stop, infinity).
  