Package jadex.platform.service.registry
Class SuperpeerClientAgent.QueryManager<T>
- java.lang.Object
-
- jadex.platform.service.registry.SuperpeerClientAgent.QueryManager<T>
-
- Enclosing class:
- SuperpeerClientAgent
protected class SuperpeerClientAgent.QueryManager<T> extends java.lang.Object
Internal handler for each user query.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.Collection<ITerminableIntermediateFuture<T>>
futures
The auxiliary futures as received from superpeers.protected MultiCollection<ISuperpeerService,java.lang.String>
networkspersuperpeer
The map of handled networks by each superpeer.protected ServiceQuery<T>
query
The query itself.protected SubscriptionIntermediateFuture<T>
retfut
The return future to the user.
-
Constructor Summary
Constructors Modifier Constructor Description protected
QueryManager(ServiceQuery<T> query)
Create a query manager and start query handling.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ISubscriptionIntermediateFuture<T>
getReturnFuture()
The return future for the user containing all the collected results from the internal queries.protected void
updateQuery(java.lang.String[] networknames)
Add/update query connections to relevant super peers for given networks.
-
-
-
Field Detail
-
query
protected ServiceQuery<T> query
The query itself.
-
retfut
protected SubscriptionIntermediateFuture<T> retfut
The return future to the user.
-
networkspersuperpeer
protected MultiCollection<ISuperpeerService,java.lang.String> networkspersuperpeer
The map of handled networks by each superpeer.
-
futures
protected java.util.Collection<ITerminableIntermediateFuture<T>> futures
The auxiliary futures as received from superpeers.
-
-
Constructor Detail
-
QueryManager
protected QueryManager(ServiceQuery<T> query)
Create a query manager and start query handling.
-
-
Method Detail
-
getReturnFuture
public ISubscriptionIntermediateFuture<T> getReturnFuture()
The return future for the user containing all the collected results from the internal queries.
-
updateQuery
protected void updateQuery(java.lang.String[] networknames)
Add/update query connections to relevant super peers for given networks.
-
-