anchor.diff:      %% Repond to coordinator that we are now committed.
       MyNode = partisan_peer_service_manager:mynode(),
       lager:info("~p: sending commit ack message to node ~p: ~p", [node(), Coordinator, Id]),
  -    partisan_pluggable_peer_service_manager:forward_message(Coordinator, undefined, ?MODULE, {commit_ack, MyNode, Id}, []),
  +    Manager:forward_message(Coordinator, undefined, ?MODULE, {commit_ack, MyNode, Id}, []),
   
       {noreply, State};
   handle_info({precommit_ack, FromNode, Id}, State) ->
  +    Manager = manager(),
  +
       %% Find transaction record.
       case ets:lookup(?COORDINATING_TRANSACTIONS, Id) of 
           [{_Id, #transaction{from=From, participants=Participants, precommitted=Precommitted0} = Transaction0}] ->
  
positive.code:     %% Repond to coordinator that we are now prepared.
      MyNode = partisan_peer_service_manager:mynode(),
      lager:info("~p: sending prepared message to node ~p: ~p", [node(), Coordinator, Id]),
      partisan_pluggable_peer_service_manager:forward_message(Coordinator, undefined, ?MODULE, {prepared, MyNode, Id}, []),
  
      {noreply, State};
  handle_info(Msg, State) ->
  
negative.code: 
                      %% Reply to caller.
                      lager:info("replying to the caller: ~p", From),
                      Manager:forward_message(From, ok),
  
                      %% Update local state before sending decision to participants.
                      Transaction = Transaction0#transaction{coordinator_status=CoordinatorStatus, precommitted=Precommitted},
  