org.apache.sling.discovery.oak

Class OakDiscoveryService

java.lang.Object

org.apache.sling.discovery.base.commons.BaseDiscoveryService

org.apache.sling.discovery.oak.OakDiscoveryService

All Implemented Interfaces:

DiscoveryService

@Service(value={DiscoveryService.class,OakDiscoveryService.class})
public class OakDiscoveryService
extends BaseDiscoveryService

This implementation of the cross-cluster service uses the view manager implementation for detecting changes in a cluster and only supports one cluster (of which this instance is part of).

Constructor Summary

Constructors

Constructor and Description
OakDiscoveryService()

Method Summary

Modifier and Type	Method and Description
protected void	activate(org.osgi.framework.BundleContext bundleContext) Activate this service
protected void	bindPropertyProvider(PropertyProvider propertyProvider, Map<String,Object> props) Bind a new property provider.
protected void	bindTopologyEventListener(TopologyEventListener eventListener) bind a topology event listener
void	checkForTopologyChange() Check the current topology for any potential change
protected void	deactivate() Deactivate this service
protected AnnouncementRegistry	getAnnouncementRegistry()
protected ClusterViewService	getClusterViewService()
ViewStateManager	getViewStateManager() for testing only
protected void	handleIsolatedFromTopology()
void	handleTopologyChanging() Handle the fact that the topology has started to change - inform the listeners asap
static OakDiscoveryService	testConstructor(SlingSettingsService settingsService, AnnouncementRegistry announcementRegistry, ConnectorRegistry connectorRegistry, ClusterViewService clusterViewService, Config config, OakViewChecker connectorPinger, Scheduler scheduler, IdMapService idMapService, OakBacklogClusterSyncService oakBacklogClusterSyncService, SyncTokenService syncTokenService, ResourceResolverFactory factory)
protected void	unbindPropertyProvider(PropertyProvider propertyProvider, Map<String,Object> props) Unbind a property provider
protected void	unbindTopologyEventListener(TopologyEventListener eventListener) Unbind a topology event listener
protected void	updatedPropertyProvider(PropertyProvider propertyProvider, Map<String,Object> props) Update a property provider.
void	updateProperties() Update the properties and sent a topology event if applicable

Methods inherited from class org.apache.sling.discovery.base.commons.BaseDiscoveryService

getOldView, getTopology, setOldView

Methods inherited from class java.lang.Object

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

Constructor Detail

OakDiscoveryService

public OakDiscoveryService()

Method Detail

testConstructor

public static OakDiscoveryService testConstructor(SlingSettingsService settingsService,
                                                  AnnouncementRegistry announcementRegistry,
                                                  ConnectorRegistry connectorRegistry,
                                                  ClusterViewService clusterViewService,
                                                  Config config,
                                                  OakViewChecker connectorPinger,
                                                  Scheduler scheduler,
                                                  IdMapService idMapService,
                                                  OakBacklogClusterSyncService oakBacklogClusterSyncService,
                                                  SyncTokenService syncTokenService,
                                                  ResourceResolverFactory factory)

handleIsolatedFromTopology

protected void handleIsolatedFromTopology()

Specified by:

handleIsolatedFromTopology in class BaseDiscoveryService

activate

@Activate
protected void activate(org.osgi.framework.BundleContext bundleContext)

Activate this service

deactivate

@Deactivate
protected void deactivate()

Deactivate this service

bindTopologyEventListener

protected void bindTopologyEventListener(TopologyEventListener eventListener)

bind a topology event listener

unbindTopologyEventListener

protected void unbindTopologyEventListener(TopologyEventListener eventListener)

Unbind a topology event listener

bindPropertyProvider

protected void bindPropertyProvider(PropertyProvider propertyProvider,
                                    Map<String,Object> props)

Bind a new property provider.

updatedPropertyProvider

protected void updatedPropertyProvider(PropertyProvider propertyProvider,
                                       Map<String,Object> props)

Update a property provider.

unbindPropertyProvider

protected void unbindPropertyProvider(PropertyProvider propertyProvider,
                                      Map<String,Object> props)

Unbind a property provider

updateProperties

public void updateProperties()

Update the properties and sent a topology event if applicable

checkForTopologyChange

public void checkForTopologyChange()

Check the current topology for any potential change

handleTopologyChanging

public void handleTopologyChanging()

Handle the fact that the topology has started to change - inform the listeners asap

getClusterViewService

protected ClusterViewService getClusterViewService()

Specified by:

getClusterViewService in class BaseDiscoveryService

getAnnouncementRegistry

protected AnnouncementRegistry getAnnouncementRegistry()

Specified by:

getAnnouncementRegistry in class BaseDiscoveryService

getViewStateManager

public ViewStateManager getViewStateManager()

for testing only

Returns: