anchor.diff:      lager:info("~p: node ~p storing updated value key ~p value ~p", [?MODULE, node(), Key, Value]),
   
       %% Send write acknowledgement.
  -    Manager = partisan_config:get(partisan_peer_service_manager),
  -    ok = Manager:forward_message(FromNode, undefined, ?MODULE, {collaborate_ack, From, Key, Value}, []),
  +    forward_message(FromNode, {collaborate_ack, From, Key, Value}),
       lager:info("~p: node ~p acknowledging value for key ~p value ~p", [?MODULE, node(), Key, Value]),
   
       %% Send backup message to backups.
       lists:foreach(fun(Backup) ->
  -        ok = Manager:forward_message(Backup, undefined, ?MODULE, {backup, From, Key, Value}, [])
  +        forward_message(Backup, {backup, From, Key, Value})
       end, Backups),
   
       %% On ack, reply to caller.
  
positive.code: 
  %%%===================================================================
  %%% Internal functions
  %%%===================================================================
negative.code: 
              %% Forward to collaboration message.
              FromNode = partisan_peer_service_manager:myself(),
              forward_message(Collaborator, {collaborate, From, FromNode, Key, Value}),
              lager:info("~p: node ~p sent replication request for key ~p with value ~p", [?MODULE, node(), Key, Value]),
  
              %% Wait for collaboration ack before proceeding for n-host resilience (n = 2).
  