VendorSearchCallback

gistfile1.java

public interface VendorQueryCallback extends ClientCallback<SearchResponse>{
	ActionFuture<SearchResponse> execute(final Client client);
}


public class VendorQueryCallbackImpl implements VendorQueryCallback {
	private final VendorSearchQuery query;
	
	public VendorQueryCallbackImpl(VendorSearchQuery query) {
		this.query = query;
	}

	@Override
	public ActionFuture<SearchResponse> execute(Client client) {
		
		final SearchRequest request = Requests.searchRequest().searchType(SearchType.DFS_QUERY_AND_FETCH);
		final SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
		
		sourceBuilder.query("");

		sourceBuilder.size(query.getLimit());
		sourceBuilder.from(query.getOffset());
		request.source(sourceBuilder);
		return client.search(request);
	}
}


public SearchResult<NetworkMembership> search(final VendorSearchQuery vendorSearchQuery, Network... indexOwners) {
		SearchResponse response = nodeTemplate.executeGet(new VendorQueryCallbackImpl(vendorSearchQuery));
		return toSearchResult(vendorSearchQuery,response);
	}