anchor.diff:      %% 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]),
  -    Manager:forward_message(Coordinator, ?GOSSIP_CHANNEL, ?MODULE, {prepared, MyNode, Id}, []),
  +    partisan_pluggable_peer_service_manager:forward_message(Coordinator, undefined, ?MODULE, {prepared, MyNode, Id}, []),
   
       {noreply, State};
   handle_info(Msg, State) ->
  
positive.code:                     %% Send commit to participants.
                      lists:foreach(fun(N) ->
                          lager:info("~p: sending commit message to node ~p: ~p", [node(), N, Id]),
                          Manager:forward_message(N, ?GOSSIP_CHANNEL, ?MODULE, {commit, Transaction}, [])
                      end, membership(Participants));
                  _ ->
                      %% Write log record showing abort occurred.
  
negative.code: 
      {noreply, State};
  handle_info({coordinator_timeout, Id}, State) ->
      %% Find transaction record.
      case ets:lookup(?COORDINATING_TRANSACTIONS, Id) of 
          [{_Id, #transaction{coordinator_status=CoordinatorStatus, participants=Participants, from=From} = Transaction0}] ->
  