anchor.diff:      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) ->
  -        forward_message(Backup, {backup, From, Key, Value})
  -    end, Backups),
  +    lists:foreach(fun(Backup) -> forward_message(Backup, {backup, From, Key, Value}) end, Backups),
   
       %% On ack, reply to caller.
       gen_server:reply(From, ok),
  
positive.code:                     lager:info("~p: node ~p ack received for key ~p value ~p", [?MODULE, node(), Key, Value]),
                      {reply, ok, State#state{store=Store}}
              after
                  ?PB_RETRY_TIMEOUT ->
                      {reply, {error, timeout}, State}
              end;
          _ ->
              {reply, {error, {primary, Primary}}, State}
      end;
  handle_call({read, Key}, _From, #state{nodes=[Primary|_Rest], store=Store}=State) ->
      case node() of 
          Primary ->
              Value = case dict:find(Key, Store) of 
                  {ok, V} ->
                      V;
                  error ->
                      not_found
              end,
              lager:info("~p: node ~p received read for key ~p and returning value ~p", [?MODULE, node(), Key, Value]),
              {reply, {ok, Value}, State};
          _ ->
              {reply, {error, {primary, Primary}}, State}
      end;
  handle_call(_Msg, _From, State) ->
      {reply, ok, State}.
  
negative.code: %% @private
  forward_message(Destination, Message) ->
      Manager = partisan_config:get(partisan_peer_service_manager),
      Manager:forward_message(Destination, undefined, ?MODULE, Message, [{ack, true}]).
  
  %% @private
  read(Key, Store) ->
      case dict:find(Key, Store) of 
          {ok, V} ->
              V;
          error ->
              not_found
      end.