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]),
  -        partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {prepare, Transaction}, [])
  +        Manager:forward_message(N, ?GOSSIP_CHANNEL, ?MODULE, {prepare, Transaction}, [])
       end, membership(Membership)),
   
       {noreply, State};
  
positive.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.
  
negative.code: 
      {noreply, State};
  handle_info({prepare, #transaction{coordinator=Coordinator, id=Id}=Transaction}, State) ->
      Manager = manager(),
  
      %% Durably store the message for recovery.
      true = ets:insert(?PARTICIPATING_TRANSACTIONS, {Id, Transaction#transaction{participant_status=prepared}}),
  
  