anchor.diff:              {reply, antidote_pb_codec:encode(get_log_operations_response,
                                                {ok, lists:zip(Objects,Results)}),
                State}
  -    end;
  -process(Blah, State) ->
  -    lager:info("blah ~p", [Blah]),
  -    {reply, ok, State}.
  +    end.
   
   %% @doc process_stream/3 callback. This service does not create any
   %% streaming responses and so ignores all incoming messages.
  
positive.code: 
  %% @doc encode/1 callback. Encodes an outgoing response message.
  encode(Message) ->
      lager:info("encoding msg ~p", [Message]),
      {ok, riak_pb_codec:encode(Message)}.
  
  process(#apbstarttransaction{timestamp=BClock, properties = BProperties},
  
negative.code: %% For legion clients
  process(#apbgetobjects{boundobjects=BoundObjects},
          State) ->
      Objects = lists:map(fun(O) ->
                                  antidote_pb_codec:decode(bound_object, O) end,
                          BoundObjects),
  