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_logger:info("~p: sending prepare message to node ~p: ~p", [node(), N, Message]),
           partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {prepare, Transaction}, [])
       end, membership(Membership)),
   
  
positive.code:                     true = ets:insert(?COORDINATING_TRANSACTIONS, {Id, Transaction0#transaction{prepared=Prepared}})
              end;
          [] ->
              lager:error("Notification for prepared message but no transaction found!")
      end,
  
      {noreply, State};
  
negative.code:                     %% Can't do anything; block.
                      ok;
                  preparing ->
                      partisan_logger:info("Received coordinator timeout for transaction id ~p", [Id]),
  
                      %% Update local state.
                      Transaction = Transaction0#transaction{coordinator_status=aborting},
                      true = ets:insert(?COORDINATING_TRANSACTIONS, {Id, Transaction}),
  
                      %% Reply to caller.
                      partisan_logger:info("Aborting transaction: ~p", [Id]),
                      partisan_pluggable_peer_service_manager:forward_message(From, error),
  
                      %% Send notification to abort.
                      lists:foreach(fun(N) ->
                          partisan_logger: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;
          [] ->
              partisan_logger:error("Notification for coordinator timeout message but no transaction found!", [])
      end,
  
      {noreply, State};
  