anchor.diff:  
   catalog_query(ConnPid, SearchQuery, MaxResults) ->
       MessageType = <<"CatalogQuery">>,
  -    CatalogQueryRec = #catalogquery{search_query=SearchQuery, 
  +    CatalogQueryRec = #catalogquery{search_query=SearchQuery,
                                       max_results=MaxResults,
                                       message_type=MessageType},
       Ref = erlang:make_ref(),
  
positive.code: 
  handle_info({tcp, Sock, Data}, #state{req_type=catalogquery, reqid=ReqId, dest=Dest}=State) ->
      CatalogQueryResponse = raptor_pb:decode_catalogqueryresponse(Data),
      Dest ! {catalog_query, ReqId, CatalogQueryResponse#catalogqueryresponse.partition, 
                                    CatalogQueryResponse#catalogqueryresponse.index, 
                                    CatalogQueryResponse#catalogqueryresponse.field, 
                                    CatalogQueryResponse#catalogqueryresponse.term, 
                                    CatalogQueryResponse#catalogqueryresponse.json_props},
      NewState = if
                     CatalogQueryResponse#catalogqueryresponse.partition =:= "$end_of_results" ->
  
negative.code:                end,
      {noreply, NewState};
  
  handle_info({tcp, _Sock, Data}, #state{req_type=command, reqid=ReqId, dest=Dest}=State) ->
      CommandResponse = raptor_pb:decode_commandresponse(Data),
      Dest ! {command, ReqId, CommandResponse#commandresponse.response},
      {noreply, State#state{req_type=undefined, reqid=undefined, dest=undefined}};
  