com.airepublic.microverse.core.discovery

Class DefaultRegistrySynchronizationStrategy

java.lang.Object

com.airepublic.microverse.core.discovery.DefaultServiceSynchronizationStrategy

com.airepublic.microverse.core.discovery.DefaultRegistrySynchronizationStrategy

All Implemented Interfaces:

IRegistrySynchronizationStrategy, IServiceSynchronizationStrategy, Closeable, AutoCloseable

@Singleton
 @RegistryStrategy
public class DefaultRegistrySynchronizationStrategy
extends DefaultServiceSynchronizationStrategy
implements IRegistrySynchronizationStrategy

Implements the synchronization strategy for the registry-server.

Author:

Torsten Oltmanns

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	HEARTBEAT_SERVICE_PERIOD

Fields inherited from class com.airepublic.microverse.core.discovery.DefaultServiceSynchronizationStrategy

HEARTBEAT_REGISTRY_PERIOD

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultRegistrySynchronizationStrategy() Constructor.
protected	DefaultRegistrySynchronizationStrategy(RegistryCache registryCache, MulticastRegistryDiscoverer registryDiscoverer) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addRegistry(RegistryDescriptor newRegistryDescriptor)
void	addService(ServiceDescriptor serviceDescriptor)
void	close()
static DefaultRegistrySynchronizationStrategy	create() Creates a new DefaultRegistrySynchronizationStrategy.
protected IMarshaller	determineCommonMimeType(RegistryDescriptor registryDescriptor) Determine which mime-type and corresponding marshaller is mutually supported by this lookup and the registry-server.
ServiceCache	getServiceCache()
void	initialize()
void	removeRegistry(RegistryDescriptor oldRegistryDescriptor)
void	removeService(ServiceDescriptor serviceDescriptor)

Methods inherited from class com.airepublic.microverse.core.discovery.DefaultServiceSynchronizationStrategy

callHeartbeat, getRegistryCache, getTimer, removeServices, requestAllRegistries

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.airepublic.microverse.core.discovery.IServiceSynchronizationStrategy

removeServices, requestAllRegistries

Field Detail

HEARTBEAT_SERVICE_PERIOD

protected static final long HEARTBEAT_SERVICE_PERIOD

See Also:

Constant Field Values

Constructor Detail

DefaultRegistrySynchronizationStrategy

protected DefaultRegistrySynchronizationStrategy()

Constructor.

DefaultRegistrySynchronizationStrategy

protected DefaultRegistrySynchronizationStrategy(RegistryCache registryCache,
                                                 MulticastRegistryDiscoverer registryDiscoverer)

Constructor.

Method Detail

create

public static DefaultRegistrySynchronizationStrategy create()
                                                     throws ServiceException

Creates a new DefaultRegistrySynchronizationStrategy.

Throws:

ServiceException

initialize

@PostConstruct
public void initialize()

Overrides:

initialize in class DefaultServiceSynchronizationStrategy

addService

public void addService(ServiceDescriptor serviceDescriptor)
                throws ServiceException

Specified by:

addService in interface IServiceSynchronizationStrategy

Overrides:

addService in class DefaultServiceSynchronizationStrategy

Throws:

ServiceException

removeService

public void removeService(ServiceDescriptor serviceDescriptor)
                   throws ServiceException

Specified by:

removeService in interface IServiceSynchronizationStrategy

Overrides:

removeService in class DefaultServiceSynchronizationStrategy

Throws:

ServiceException

addRegistry

public void addRegistry(RegistryDescriptor newRegistryDescriptor)
                 throws ServiceException

Specified by:

addRegistry in interface IRegistrySynchronizationStrategy

Throws:

ServiceException

removeRegistry

public void removeRegistry(RegistryDescriptor oldRegistryDescriptor)
                    throws ServiceException

Specified by:

removeRegistry in interface IRegistrySynchronizationStrategy

Throws:

ServiceException

determineCommonMimeType

protected IMarshaller determineCommonMimeType(RegistryDescriptor registryDescriptor)
                                       throws ServiceException

Determine which mime-type and corresponding marshaller is mutually supported by this lookup and the registry-server.

Overrides:

determineCommonMimeType in class DefaultServiceSynchronizationStrategy

Parameters:

registryDescriptor - the RegistryDescriptor

Returns:

a IMarshaller or null

Throws:

ServiceException

getServiceCache

public ServiceCache getServiceCache()

Specified by:

getServiceCache in interface IRegistrySynchronizationStrategy

close

public void close()

Specified by:

close in interface IServiceSynchronizationStrategy

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class DefaultServiceSynchronizationStrategy