anchor.diff:  	{ok, ChannelOut} = amqp_connection:open_channel(Connection),
   	
   	%% Declare INPUT queues and subscribe.
  -	Queues = declare_input_queues(ChannelIn, InputExchanges),
  -	%subscribe(ChannelIn, Queues),
  +	subscribe(ChannelIn, InputExchanges),
   	
   	%% Declare OUTPUT exchange.
   	amqp_channel:call(ChannelOut,
  
positive.code: 
  
  %% @doc
  %% Function: declare_input_queues/2
  %% Purpose: Used to create a queue for each exchange in the list on a channel.
  %% Args: ChannelIn - The channel on which communication to the server occurs,
  %%       InputExchanges - The list of exchanges.
  %% Returns: [] | [Queue]
  %% @end 
  -spec declare_input_queues(ChannelIn :: pid(), InputExchanges :: [binary()]) ->
  		  [] | [Queue :: binary()].
  declare_input_queues(ChannelIn, InputExchanges) ->
  	declare_input_queues(ChannelIn, InputExchanges, []).
  
  %% @doc
  %% Function: declare_input_queues/3
  %% Purpose: Used to create a queue for each exchange in the list on a channel.
  %% Args: ChannelIn - The channel on which communication to the server occurs,
  %%       InputExchanges - The list of exchanges.
  %%       Queues - The list of where to store the new queues.
  %% Returns: Queues | [Queue] ++ Queues.
  %% @end 
  -spec declare_input_queues(ChannelIn :: pid(), InputExchanges :: [binary()],
  						   Queues) -> Queues | [Queue | Queues] when
  		  Queues :: list(),
  		  Queue :: binary().
  declare_input_queues(_ChannelIn, [], Queues) -> Queues;
  declare_input_queues(ChannelIn, [InputExchange | InputExchanges], Queues) ->
  	%% Declare INPUT queues
  	amqp_channel:call(ChannelIn,
  					  #'exchange.declare'{exchange = InputExchange,
  
negative.code: 	receive
  		#'basic.consume_ok'{} -> ok
  	end,
  	subscribe(ChannelIn, InputExchanges).
  
  
  
  
  