anchor.diff:  
       {noreply, State};
   handle_info({abort, #transaction{id=Id, coordinator=Coordinator}}, State) ->
  -    Manager = manager(),
  -
       true = ets:delete(?PARTICIPATING_TRANSACTIONS, Id),
   
       MyNode = partisan_peer_service_manager:mynode(),
       lager:info("~p: sending abort ack message to node ~p: ~p", [node(), Coordinator, Id]),
  -    Manager:forward_message(Coordinator, undefined, ?MODULE, {abort_ack, MyNode, Id}, []),
  +    partisan_pluggable_peer_service_manager:forward_message(Coordinator, undefined, ?MODULE, {abort_ack, MyNode, Id}, []),
   
       {noreply, State};
   handle_info({commit, #transaction{id=Id, coordinator=Coordinator, server_ref=ServerRef, message=Message} = Transaction}, State) ->
  -    Manager = manager(),
  -
       %% Write log record showing commit occurred.
       true = ets:insert(?PARTICIPATING_TRANSACTIONS, {Id, Transaction#transaction{participant_status=commit}}),
   
  
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, undefined, ?MODULE, {commit, Transaction}, [])
                      end, membership(Participants));
                  _ ->
                      %% Write log record showing abort occurred.
  
negative.code:                     %% Send notification to commit.
                      lists:foreach(fun(N) ->
                          lager:info("~p: sending precommit message to node ~p: ~p", [node(), N, Id]),
                          partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {precommit, Transaction}, [])
                      end, membership(Participants));
                  false ->
                      %% Update local state before sending decision to participants.
  