CachingFederationStrategy
provided by the catalog-core-standardframework
bundle.@Deprecated public class FifoFederationStrategy extends Object implements FederationStrategy
FifoFederationStrategy
represents a First In First Out (FIFO) federation
strategy that returns results in the order they are received. This means that the first results
received by this strategy are the first results sent back to the client.Constructor and Description |
---|
FifoFederationStrategy(ExecutorService queryExecutorService,
List<PreFederatedQueryPlugin> preQuery,
List<PostFederatedQueryPlugin> postQuery)
Deprecated.
Instantiates a
FifoFederationStrategy with the provided ExecutorService . |
Modifier and Type | Method and Description |
---|---|
protected QueryResponse |
executePostFederationPlugins(QueryResponse queryResponse)
Deprecated.
|
protected void |
executeSourceQueries(List<Source> sources,
Map<Source,Future<SourceResponse>> futures,
QueryRequest modifiedQueryRequest)
Deprecated.
|
QueryResponse |
federate(List<Source> sources,
QueryRequest queryRequest)
Deprecated.
Federate the given query to the
List of Source s, returning a QueryResponse back to the user that will include the matching Result s. |
protected Query |
getModifiedQuery(Query originalQuery,
int numberOfSources,
int offset,
int pageSize)
Deprecated.
|
public FifoFederationStrategy(ExecutorService queryExecutorService, List<PreFederatedQueryPlugin> preQuery, List<PostFederatedQueryPlugin> postQuery)
FifoFederationStrategy
with the provided ExecutorService
.queryExecutorService
- the ExecutorService
for queriespublic QueryResponse federate(List<Source> sources, QueryRequest queryRequest)
FederationStrategy
List
of Source
s, returning a QueryResponse
back to the user that will include the matching Result
s.federate
in interface FederationStrategy
sources
- the List
of Source
s to be queried. Cannot be null
or
empty.queryRequest
- the QueryRequest
to execute. Cannot be null
.QueryResponse
which contains the list of Result
s.protected QueryResponse executePostFederationPlugins(QueryResponse queryResponse)
protected void executeSourceQueries(List<Source> sources, Map<Source,Future<SourceResponse>> futures, QueryRequest modifiedQueryRequest)
This work is licensed under a Creative Commons Attribution 4.0 International License.