jadex.platform.service.dht

Class DistributedServiceRegistryService

java.lang.Object

jadex.platform.service.dht.DistributedKVStoreService

jadex.platform.service.dht.DistributedServiceRegistryService

All Implemented Interfaces:

jadex.bridge.service.types.dht.IDistributedKVStoreDebugService, jadex.bridge.service.types.dht.IDistributedKVStoreService, jadex.bridge.service.types.dht.IDistributedServiceRegistryService

public class DistributedServiceRegistryService
extends DistributedKVStoreService
implements jadex.bridge.service.types.dht.IDistributedServiceRegistryService

Distributed Service Registry

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	CHECK_LEASE_DELAY Delay in ms between two stabilize runs

Fields inherited from class jadex.platform.service.dht.DistributedKVStoreService

agent, CHECK_STORED_DATA_DELAY, checkDataStep, executor, initialized, keyMap, logger, myId, ring

Constructor Summary

Constructors

Constructor and Description
DistributedServiceRegistryService()

Method Summary

Modifier and Type	Method and Description
protected jadex.commons.future.IFuture<java.lang.Void>	checkValidity() Check the validity of all entries and remove them, if invalid.
jadex.commons.future.IFuture<java.util.Collection<jadex.bridge.service.types.dht.ServiceRegistration>>	lookup(java.lang.String key) Lookup a key in the ring and return the saved value, if any.
jadex.commons.future.IFuture<java.util.Collection<jadex.bridge.service.types.dht.ServiceRegistration>>	lookup(java.lang.String key, jadex.bridge.service.types.dht.IID idHash) Lookup a key in the ring and return the saved value, if any.
void	onServiceStarted()
jadex.commons.future.IFuture<java.lang.Void>	publish(java.lang.String typeName, jadex.bridge.service.IServiceIdentifier serviceIdentifier) Publish a service in the distributed registry.
protected jadex.commons.future.IFuture<jadex.bridge.service.types.dht.IID>	storeLocal(jadex.bridge.service.types.dht.IID hash, java.lang.String key, java.lang.Object value, boolean addToCollection) Store a key/value pair in the local map.

Methods inherited from class jadex.platform.service.dht.DistributedKVStoreService

add, checkData, disableSchedules, eventReceived, getLocalKeySet, getStoreService, isInitialized, log, lookupResponsibleStore, pullEntries, pushEntries, put, setInitialized, setRingService, store, store

Methods inherited from class java.lang.Object

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

Methods inherited from interface jadex.bridge.service.types.dht.IDistributedKVStoreService

add, getLocalKeySet, isInitialized, lookupResponsibleStore, pullEntries, pushEntries, put, setInitialized, setRingService

Field Detail

CHECK_LEASE_DELAY

protected static final long CHECK_LEASE_DELAY

Delay in ms between two stabilize runs

See Also:

Constant Field Values

Constructor Detail

DistributedServiceRegistryService

public DistributedServiceRegistryService()

Method Detail

onServiceStarted

public void onServiceStarted()

Overrides:

onServiceStarted in class DistributedKVStoreService

publish

public jadex.commons.future.IFuture<java.lang.Void> publish(java.lang.String typeName,
                                                            jadex.bridge.service.IServiceIdentifier serviceIdentifier)

Publish a service in the distributed registry.

Specified by:

publish in interface jadex.bridge.service.types.dht.IDistributedServiceRegistryService

Parameters:

typeName - Type of the service (fully-qualified)

serviceIdentifier - SID of the service

Returns:

Void

storeLocal

protected jadex.commons.future.IFuture<jadex.bridge.service.types.dht.IID> storeLocal(jadex.bridge.service.types.dht.IID hash,
                                                                                      java.lang.String key,
                                                                                      java.lang.Object value,
                                                                                      boolean addToCollection)

Description copied from class: DistributedKVStoreService

Store a key/value pair in the local map.

Overrides:

storeLocal in class DistributedKVStoreService

Parameters:

hash - The hash

key - The key

value - The value

Returns:

the ID of the local node.

lookup

public jadex.commons.future.IFuture<java.util.Collection<jadex.bridge.service.types.dht.ServiceRegistration>> lookup(java.lang.String key)

Description copied from class: DistributedKVStoreService

Lookup a key in the ring and return the saved value, if any.

Specified by:

lookup in interface jadex.bridge.service.types.dht.IDistributedKVStoreService

Specified by:

lookup in interface jadex.bridge.service.types.dht.IDistributedServiceRegistryService

Overrides:

lookup in class DistributedKVStoreService

Parameters:

key - Requested key.

Returns:

The retrieved value or null, if none.

lookup

public jadex.commons.future.IFuture<java.util.Collection<jadex.bridge.service.types.dht.ServiceRegistration>> lookup(java.lang.String key,
                                                                                                                     jadex.bridge.service.types.dht.IID idHash)

Description copied from class: DistributedKVStoreService

Lookup a key in the ring and return the saved value, if any.

Specified by:

lookup in interface jadex.bridge.service.types.dht.IDistributedKVStoreService

Specified by:

lookup in interface jadex.bridge.service.types.dht.IDistributedServiceRegistryService

Overrides:

lookup in class DistributedKVStoreService

Parameters:

key - Requested key.

idHash - The hashed key to find the corresponding node.

Returns:

The retrieved value or null, if none.

checkValidity

protected jadex.commons.future.IFuture<java.lang.Void> checkValidity()

Check the validity of all entries and remove them, if invalid.

Returns:

Void