anchor.diff:  
       {noreply, State};
   handle_info({precommit, #transaction{id=Id, coordinator=Coordinator} = Transaction}, State) ->
  -    Manager = manager(),
  -
       %% Write log record showing commit occurred.
       true = ets:insert(?PARTICIPATING_TRANSACTIONS, {Id, Transaction#transaction{participant_status=precommit}}),
   
       %% Repond to coordinator that we are now committed.
       MyNode = partisan_peer_service_manager:mynode(),
  -    Manager:forward_message(Coordinator, ?GOSSIP_CHANNEL, ?MODULE, {precommit_ack, MyNode, Id}, []),
  +    partisan_pluggable_peer_service_manager:forward_message(Coordinator, undefined, ?MODULE, {precommit_ack, MyNode, Id}, []),
   
       {noreply, State};
   handle_info({prepared, FromNode, Id}, State) ->
  -    Manager = manager(),
  -
       %% Find transaction record.
       case ets:lookup(?COORDINATING_TRANSACTIONS, Id) of 
           [{_Id, #transaction{participants=Participants, prepared=Prepared0} = Transaction0}] ->
  
positive.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]),
          Manager:forward_message(N, ?GOSSIP_CHANNEL, ?MODULE, {prepare, Transaction}, [])
      end, membership(Membership)),
  
      {noreply, State};
  
negative.code: 
  %% @private
  handle_cast({broadcast, From, ServerRef, Message}, #state{membership=Membership}=State) ->
      %% Generate unique transaction id.
      MyNode = partisan_peer_service_manager:mynode(),
      Id = {MyNode, erlang:unique_integer([monotonic, positive])},
  