anchor.diff:      %% 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}, [])
  +        partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {prepare, Transaction}, [])
       end, membership(Membership)),
   
       {noreply, State};
  
positive.code: %% @private
  %% Incoming messages.
  handle_info({decision, FromNode, Id, Decision}, State) ->
      Manager = manager(),
      MyNode = partisan_peer_service_manager:mynode(),
  
      %% Find transaction record.
  
negative.code: 
                      %% Reply to caller.
                      lager:info("Aborting transaction: ~p", [Id]),
                      partisan_pluggable_peer_service_manager:forward_message(From, error),
  
                      %% Send notification to abort.
                      lists:foreach(fun(N) ->
                          lager:info("~p: sending abort message to node ~p: ~p", [node(), N, Id]),
                          partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {abort, Transaction}, [])
                      end, membership(Participants))
              end;
          [] ->
  