com.airepublic.microverse.core.discovery

Class DefaultServiceSynchronizationStrategy

java.lang.Object

com.airepublic.microverse.core.discovery.DefaultServiceSynchronizationStrategy

All Implemented Interfaces:

IServiceSynchronizationStrategy, Closeable, AutoCloseable

Direct Known Subclasses:

DefaultRegistrySynchronizationStrategy

@Singleton
 @ServiceStrategy
public class DefaultServiceSynchronizationStrategy
extends Object
implements IServiceSynchronizationStrategy

Implements the synchronization strategy for the service-server.

Author:

Torsten Oltmanns

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	HEARTBEAT_REGISTRY_PERIOD

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addService(ServiceDescriptor serviceDescriptor)
protected Long	callHeartbeat(String host, int port, boolean useSSL, WebCall heartbeatUri) Calls the heatbeat method of the registry to determine whether its responding and if so, the latency.
void	close()
static DefaultServiceSynchronizationStrategy	create() Creates a new DefaultServiceSynchronizationStrategy.
protected IMarshaller	determineCommonMimeType(RegistryDescriptor registryDescriptor) Determine which mime-type and corresponding marshaller is mutually supported by this lookup and the registry-server.
RegistryCache	getRegistryCache()
protected Timer	getTimer() Gets the timer for the heartbeat calls.
void	initialize()
void	removeService(ServiceDescriptor serviceDescriptor)
void	removeServices(List<ServiceDescriptor> serviceDescriptors)
void	requestAllRegistries()

Methods inherited from class java.lang.Object

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

Field Detail

HEARTBEAT_REGISTRY_PERIOD

protected static final long HEARTBEAT_REGISTRY_PERIOD

See Also:

Constant Field Values

Constructor Detail

DefaultServiceSynchronizationStrategy

protected DefaultServiceSynchronizationStrategy()

Constructor.

DefaultServiceSynchronizationStrategy

protected DefaultServiceSynchronizationStrategy(RegistryCache registryCache,
                                                MulticastRegistryDiscoverer registryDiscoverer)

Constructor.

Method Detail

create

public static DefaultServiceSynchronizationStrategy create()
                                                    throws ServiceException

Creates a new DefaultServiceSynchronizationStrategy.

Throws:

ServiceException

initialize

@PostConstruct
public void initialize()

getTimer

protected Timer getTimer()

Gets the timer for the heartbeat calls.

Returns:

the Timer

callHeartbeat

protected Long callHeartbeat(String host,
                             int port,
                             boolean useSSL,
                             WebCall heartbeatUri)

Calls the heatbeat method of the registry to determine whether its responding and if so, the latency.

Parameters:

host -

port -

useSSL -

heartbeatUri -

Returns:

the latency or null if not responding

addService

public void addService(ServiceDescriptor serviceDescriptor)
                throws ServiceException

Specified by:

addService in interface IServiceSynchronizationStrategy

Throws:

ServiceException

removeService

public void removeService(ServiceDescriptor serviceDescriptor)
                   throws ServiceException

Specified by:

removeService in interface IServiceSynchronizationStrategy

Throws:

ServiceException

removeServices

public void removeServices(List<ServiceDescriptor> serviceDescriptors)
                    throws ServiceException

Specified by:

removeServices in interface IServiceSynchronizationStrategy

Throws:

ServiceException

requestAllRegistries

public void requestAllRegistries()
                          throws ServiceException

Specified by:

requestAllRegistries in interface IServiceSynchronizationStrategy

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.

Parameters:

registryDescriptor - the RegistryDescriptor

Returns:

a IMarshaller or null

Throws:

ServiceException

getRegistryCache

public RegistryCache getRegistryCache()

close

public void close()

Specified by:

close in interface IServiceSynchronizationStrategy

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable