jadex.bridge.service.search

Class GlobalQueryServiceRegistry

java.lang.Object

jadex.bridge.service.search.ServiceRegistry

jadex.bridge.service.search.GlobalQueryServiceRegistry

All Implemented Interfaces:

IRegistryDataProvider, IServiceRegistry

public class GlobalQueryServiceRegistry
extends ServiceRegistry

Registry that allows for adding global queries with local registry. Uses remote searches to emulate the persistent query.

Nested Class Summary

Nested classes/interfaces inherited from class jadex.bridge.service.search.ServiceRegistry

ServiceRegistry.UnlimitedIntermediateDelegationResultListener<E>

Field Summary

Fields

Modifier and Type	Field and Description
protected long	delay The global query delay.
protected java.util.Timer	timer The timer.

Fields inherited from class jadex.bridge.service.search.ServiceRegistry

excluded, excludedservices, listeners, queries, searchfunc, services

Constructor Summary

Constructors

Constructor and Description
GlobalQueryServiceRegistry(long delay) Create a new GlobalQueryServiceRegistry.

Method Summary

Modifier and Type	Method and Description
<T> ISubscriptionIntermediateFuture<T>	addQuery(ServiceQuery<T> query) Add a service query to the registry.
protected void	waitForDelay(long delay, java.lang.Runnable run) Wait for delay and execute runnable.

Methods inherited from class jadex.bridge.service.search.ServiceRegistry

addEventListener, addExcludedComponent, addService, getQueries, getRegistry, getRegistry, getService, getServiceMap, getServices, getSubregistry, isIncluded, notifyListeners, removeEventListener, removeExcludedComponent, removeQueries, removeQuery, removeService, removeSubregistry, searchGlobalService, searchGlobalServices, searchRemoteService, searchRemoteServices, searchService, searchService, searchService, searchService, searchServices, searchServices, searchServices

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

timer

protected java.util.Timer timer

The timer.

delay

protected long delay

The global query delay.

Constructor Detail

GlobalQueryServiceRegistry

public GlobalQueryServiceRegistry(long delay)

Create a new GlobalQueryServiceRegistry.

Method Detail

addQuery

public <T> ISubscriptionIntermediateFuture<T> addQuery(ServiceQuery<T> query)

Add a service query to the registry.

Specified by:

addQuery in interface IServiceRegistry

Overrides:

addQuery in class ServiceRegistry

Parameters:

query - ServiceQuery.

waitForDelay

protected void waitForDelay(long delay,
                            java.lang.Runnable run)

Wait for delay and execute runnable.