com.hp.util.dcord.hazelcast

Class HazelcastCoordinationService

java.lang.Object

com.hp.util.dcord.hazelcast.HazelcastCoordinationService

All Implemented Interfaces:

CoordinationService

public class HazelcastCoordinationService
extends Object
implements CoordinationService

Distributed system's coordination service using Hazelcast as the underlying technology.

Author:

Mark Mozolewski, Vamsi Devaki, Nachiket Abhyankar, Fabiel Zuniga

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,RestrictedCoordinationService>	create(HazelcastConfiguration configuration, org.slf4j.Logger logger) Creates a 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,RestrictedCoordinationService> create(HazelcastConfiguration configuration,
                                                                     org.slf4j.Logger logger)

Creates a CoordinationService

Parameters:

configuration - configuration

logger - logger

Returns:

a coordination service

registerSerializer

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

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

Throws:

UnsupportedOperationException - if this operation is not supported by the implementation

unregisterSerializer

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

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

Throws:

UnsupportedOperationException - if this operation is not supported by the implementation

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)
                  throws UnsupportedOperationException

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

Throws:

UnsupportedOperationException - if this operation is not supported by the implementation