anchor.diff:                      %% Send notification to commit.
                       lists:foreach(fun(N) ->
                           lager:info("~p: sending commit message to node ~p: ~p", [node(), N, Id]),
  -                        Manager:forward_message(N, undefined, ?MODULE, {commit, Transaction}, [])
  +                        partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {commit, Transaction}, [])
                       end, membership(Participants));
                   false ->
                       %% Update local state before sending decision to participants.
  
positive.code: 
      {noreply, State};
  handle_info({coordinator_timeout, Id}, State) ->
      Manager = manager(),
  
      %% Find transaction record.
      case ets:lookup(?COORDINATING_TRANSACTIONS, Id) of 
          [{_Id, #transaction{coordinator_status=CoordinatorStatus, participants=Participants, from=From} = Transaction0}] ->
  
negative.code:     %% Send prepare message to all participants including ourself.
      lists:foreach(fun(N) ->
          lager:info("~p: sending prepare message to node ~p: ~p", [node(), N, Message]),
          partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {prepare, Transaction}, [])
      end, membership(Membership)),
  
      {noreply, State};
  