anchor.diff:          amqp_channel:subscribe(Channel, #'basic.consume'{queue = DetourQ, no_ack = true}, self()),
   
       {noreply, State#state{in_exchange = InExchange, in_rkey = InRKey, detour_ctag = DetourCTag2,
  -                            out_exchange = OutExchange, out_rkey = OutRKey, 
  -                            detour_queue = DetourQ}};
  +                            out_exchange = OutExchange, out_rkey = OutRKey}};
   
   %% @private
   % detours a message from InExchange to OutExchange
  
positive.code:                 detour_ctag = <<"">>, %% consumer tag for the detour queue
                  out_exchange, %% exchange to publish the detoured messages.
                  out_rkey, %% key used to publish the messages.
                  detour_queue, %% priavte queue.
                  control_exchange, %% Control Bus Exchange
                  control_rkey, %% key to bind to the control bus
                  control_ctag}). %% consumer for the control bus queue
  
negative.code: start_demo(debug) ->
      demo([{debug, [trace]}]).
  
  start([Connection, ControlExchange, ControlRKey, Opts]) ->
      {ok, Pid} = gen_server:start(?MODULE, [Connection, ControlExchange, ControlRKey], Opts),
      Pid.
  
  stop(Pid) ->
      gen_server:call(Pid, stop, infinity).
  
  