anchor.diff:              send_error("~p", [Reason], State)
       end;
   
  -process_message(#rpbdelreq{bucket=B, key=K, rw=RW}, 
  -                #state{client=C} = State) ->
  +process_message(#rpbdelreq{bucket=B, key=K, rw=RW0}, 
  +                #state{client=C} = State) ->
  +    RW = case RW0 of 
  +        ?RIAKC_RW_ONE -> one;
  +        ?RIAKC_RW_QUORUM -> quorum;
  +        ?RIAKC_RW_ALL -> all;
  +        Other -> Other
  +        end,    
       case C:delete(B, K, default_rw(RW)) of
           ok ->
               send_msg(rpbdelresp, State);
  
positive.code:                                  server_version = get_riak_version()},
      send_msg(Resp, State);
  
  process_message(#rpbgetreq{bucket=B, key=K, r=R}, 
                  #state{client=C} = State) ->
      case C:get(B, K, default_r(R)) of
          {ok, O} ->
              PbContent = riakc_pb:pbify_rpbcontents(riak_object:get_contents(O), []),
  
negative.code:     end;
  
  process_message(#rpbputreq{bucket=B, key=K, vclock=PbVC, content=RpbContent,
                             w=W0, dw=DW0, return_body=ReturnBody}, 
                  #state{client=C} = State) ->
  
      O0 = riak_object:new(B, K, <<>>),  
      O1 = update_rpbcontent(O0, RpbContent),
      O  = update_pbvc(O1, PbVC),
      % erlang_protobuffs encodes as 1/0/undefined
      W = case W0 of
              ?RIAKC_RW_ONE -> one;
              ?RIAKC_RW_ALL -> all;
              ?RIAKC_RW_QUORUM -> quorum;
              Other  -> Other
          end,
      DW = case DW0 of
              ?RIAKC_RW_ONE -> one;
              ?RIAKC_RW_ALL -> all;
              ?RIAKC_RW_QUORUM -> quorum;
              Other1 -> Other1
          end,
      Options = case ReturnBody of 1 -> [returnbody]; _ -> [] end,
      case C:put(O, default_w(W), default_dw(DW), default_timeout(), Options) of
          ok ->
  