com.hp.util.dcord

Class SuspendibleCoordinationService

java.lang.Object

com.hp.util.dcord.SuspendibleCoordinationService

All Implemented Interfaces:

CoordinationService

public class SuspendibleCoordinationService
extends Object
implements CoordinationService

Wraps CoordinationService to make it suspendible.

Author:

Fabiel Zuniga, Vamsi Krishna Devaki

Method Summary

Methods

Modifier and Type	Method and Description
void	configureMap(Namespace namespace, MapConfiguration configuration) Sets a particular configuration for a distributed map.
static Restrictable<CoordinationService,SuspendibleStoppable>	create(Restrictable<CoordinationService,Stoppable> delegate) Create a suspendible CoordinationService
ClusterService	getClusterService() Gets the service to deal with the cluster.
DistributedLock	getLock(Namespace namespace) Creates a distributed lock.
<K,V> DistributedMap<K,V>	getMap(Namespace namespace) Gets a distributed map.
PublishSubscribeService	getPublishSubscribeService() Gets the service to deal with the publish-subscribe.
<T> void	registerSerializer(Serializer<T> serializer, Class<T> subject) Registers a serializer.
<T> void	unregisterSerializer(Class<T> subject) Unregisters a previously registered serializer via CoordinationService.registerSerializer(Serializer, Class).

Methods inherited from class java.lang.Object

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

Method Detail

create

public static Restrictable<CoordinationService,SuspendibleStoppable> create(Restrictable<CoordinationService,Stoppable> delegate)

Create a suspendible CoordinationService

Parameters:

delegate - CoordinationService implementation to delegate to

Returns:

suspendible CoordinationService

registerSerializer

public <T> void registerSerializer(Serializer<T> serializer,
                          Class<T> subject)

Description copied from interface: CoordinationService

Registers a serializer.

Registering serializers allows non serializable objects to be shared.

Registering serializers may be useful if the coordination service is used in component-based applications (Like OSGi where each bundle has a class loader associated) where multiple class loaders are used, making deserialization not possible for the class loader the coordination service is associated to.

Specified by:

registerSerializer in interface CoordinationService

Parameters:

serializer - serializer

subject - subject the serializer is associated to

unregisterSerializer

public <T> void unregisterSerializer(Class<T> subject)

Description copied from interface: CoordinationService

Unregisters a previously registered serializer via CoordinationService.registerSerializer(Serializer, Class).

Specified by:

unregisterSerializer in interface CoordinationService

Parameters:

subject - subject the serializer is associated to

getClusterService

public ClusterService getClusterService()

Description copied from interface: CoordinationService

Gets the service to deal with the cluster.

Specified by:

getClusterService in interface CoordinationService

Returns:

the cluster service

getPublishSubscribeService

public PublishSubscribeService getPublishSubscribeService()

Description copied from interface: CoordinationService

Gets the service to deal with the publish-subscribe.

Specified by:

getPublishSubscribeService in interface CoordinationService

Returns:

the publish-subscribe service

getLock

public DistributedLock getLock(Namespace namespace)

Description copied from interface: CoordinationService

Creates a distributed lock.

See LockCriticalSectionExecutor for a higher level synchronization abstraction.

Specified by:

getLock in interface CoordinationService

Parameters:

namespace - lock's namespace

Returns:

a distributed lock

getMap

public <K,V> DistributedMap<K,V> getMap(Namespace namespace)

Description copied from interface: CoordinationService

Gets a distributed map.

Specified by:

getMap in interface CoordinationService

Type Parameters:

K - the type of keys maintained by this map. This type should be immutable: The state of the distributed data structure is synchronized but not the state if its elements. It is critical this type implements equals() and hashCode() correctly.

V - the type of mapped values. This type should be immutable: The state of the distributed data structure is synchronized but not the state if its elements.

Parameters:

namespace - map's namespace

Returns:

a distributed map

configureMap

public void configureMap(Namespace namespace,
                MapConfiguration configuration)

Description copied from interface: CoordinationService

Sets a particular configuration for a distributed map.

A map must be configured before it is used for the first time. Changing the configuration after the map has been used is not defined and thus it depends on the implementation (It may lead to unexpected behaviors).

Specified by:

configureMap in interface CoordinationService

Parameters:

namespace - map's namespace

configuration - configuration