anchor.diff:  	    end
       end.
   
  -active(#state{identity=Id, amqp_connect_args = AMQPConnectArgs, ch_pid=Channel, conn_pid=Connection, received=LastMsg} = State, Parent, Deb) ->
  +active(#state{identity = Id, amqp_connect_args = AMQPConnectArgs, ch_pid = Channel, conn_pid = Connection, received = LastMsg} = State, Parent, Deb) ->
       receive
   	{'EXIT', Parent, Reason} ->
   	    amqp_channel:close(Channel),
  
positive.code: -record(subscribe, {from}).
  
  start_link() ->
      start_link(#amqp_connect_args{exch=?exch, queue=?queue}).
  
  start_link(Args) ->
      proc_lib:start_link(?MODULE, init, [self(), Args]).
  
negative.code: system_continue(Parent, Deb, State) ->
      active(State, Parent, Deb).
  
  system_terminate(Reason, _Parent, Deb, #state{ch_pid = Channel, conn_pid = Connection, received = _LastMsg}) ->
      sys:handle_debug(Deb, fun ?MODULE:write_debug/3, ?MODULE, {shutdown, Reason}),
      amqp_channel:close(Channel),
      amqp_connection:close(Connection),
  