anchor.diff:           handle_info/2,
            terminate/2,
            code_change/3]).
  -
  --compile([{parse_transform, lager_transform}]).
   
   -record(state, {next_id, membership}).
   
  
positive.code:                     true = ets:insert(?COORDINATING_TRANSACTIONS, {Id, Transaction}),
  
                      %% Reply to caller.
                      lager:info("replying to the caller: ~p", From),
                      partisan_pluggable_peer_service_manager:forward_message(From, ok),
  
                      %% Send notification to commit.
                      lists:foreach(fun(N) ->
                          lager:info("~p: sending commit message to node ~p: ~p", [node(), N, Id]),
                          partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {commit, Transaction}, [])
                      end, membership(Participants));
                  false ->
  
negative.code: 
      MyNode = partisan_peer_service_manager:mynode(),
  
      partisan_logger:info("~p: sending abort ack message to node ~p: ~p", [node(), Coordinator, Id]),
      partisan_pluggable_peer_service_manager:forward_message(Coordinator, undefined, ?MODULE, {abort_ack, MyNode, Id}, []),
  
      {noreply, State};
  