anchor.diff:  	    Deb2 = sys:handle_debug(Deb, fun ?MODULE:write_debug/3, ?MODULE, {received_msg_with_payload, Payload}),
   	    amqp_channel:cast(Channel, #'basic.ack'{delivery_tag = Tag}),
   	    Deb3 = sys:handle_debug(Deb2, fun ?MODULE:write_debug/3, ?MODULE, {sent_ack}),
  -	    New_state = #state{identity=Id, amqp_connect_args = AMQPConnectArgs, ch_pid=Channel, conn_pid=Connection, received=binary_to_term(Payload)},
  +	    New_state = #state{identity = Id, amqp_connect_args = AMQPConnectArgs, ch_pid = Channel, conn_pid = Connection, received = binary_to_term(Payload)},
   	    active(New_state, Parent, Deb3);
   	#subscribe{from = _From} ->
   	    % if not has been subscribed
   	    active(State, Parent, Deb);
  -	    #cask4_consumer_msg{from = From} ->
  +	#cask4_consumer_msg{from = From} ->
   	    From ! LastMsg,
   	    Deb2 = sys:handle_debug(Deb, fun ?MODULE:write_debug/3, ?MODULE, {received_cask_consume_msg}),
   	    active(State, Parent, Deb2)
  
positive.code: 	    end
      end.
  
  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),
  
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),
  