@Service(value=OakViewChecker.class) @Reference(referenceInterface=org.osgi.service.http.HttpService.class, cardinality=OPTIONAL_MULTIPLE, policy=DYNAMIC) public class OakViewChecker extends org.apache.sling.discovery.base.commons.BaseViewChecker
Remote heartbeats are POSTs to remote TopologyConnectorServlets using discovery.base
Modifier and Type | Field and Description |
---|---|
protected org.apache.sling.discovery.base.connectors.announcement.AnnouncementRegistry |
announcementRegistry |
protected org.apache.sling.discovery.base.connectors.ping.ConnectorRegistry |
connectorRegistry |
protected org.apache.sling.discovery.base.commons.PeriodicBackgroundJob |
periodicCheckViewJob |
protected org.apache.sling.api.resource.ResourceResolverFactory |
resourceResolverFactory |
protected org.apache.sling.commons.scheduler.Scheduler |
scheduler |
protected org.apache.sling.settings.SlingSettingsService |
slingSettingsService |
Constructor and Description |
---|
OakViewChecker() |
Modifier and Type | Method and Description |
---|---|
protected void |
deactivate() |
protected void |
doActivate() |
protected void |
doCheckView() |
protected org.apache.sling.discovery.base.connectors.announcement.AnnouncementRegistry |
getAnnouncementRegistry() |
protected org.apache.sling.discovery.base.connectors.BaseConfig |
getConnectorConfig() |
protected org.apache.sling.discovery.base.connectors.ping.ConnectorRegistry |
getConnectorRegistry() |
protected org.apache.sling.api.resource.ResourceResolverFactory |
getResourceResolverFactory() |
protected org.apache.sling.commons.scheduler.Scheduler |
getScheduler() |
protected org.apache.sling.settings.SlingSettingsService |
getSlingSettingsService() |
void |
initialize(OakDiscoveryService discoveryService)
The initialize method is called by the OakDiscoveryService.activate
as we require the discoveryService (and the discoveryService has
a reference on us - but we cant have circular references in osgi).
|
boolean |
resetLeaderElectionId()
Hook that will cause a reset of the leaderElectionId
on next invocation of issueClusterLocalHeartbeat.
|
static OakViewChecker |
testConstructor(org.apache.sling.settings.SlingSettingsService slingSettingsService,
org.apache.sling.api.resource.ResourceResolverFactory resourceResolverFactory,
org.apache.sling.discovery.base.connectors.ping.ConnectorRegistry connectorRegistry,
org.apache.sling.discovery.base.connectors.announcement.AnnouncementRegistry announcementRegistry,
org.apache.sling.commons.scheduler.Scheduler scheduler,
Config config)
for testing only
|
protected void |
updateProperties() |
@Reference protected org.apache.sling.settings.SlingSettingsService slingSettingsService
@Reference protected org.apache.sling.api.resource.ResourceResolverFactory resourceResolverFactory
@Reference protected org.apache.sling.discovery.base.connectors.ping.ConnectorRegistry connectorRegistry
@Reference protected org.apache.sling.discovery.base.connectors.announcement.AnnouncementRegistry announcementRegistry
@Reference protected org.apache.sling.commons.scheduler.Scheduler scheduler
protected org.apache.sling.discovery.base.commons.PeriodicBackgroundJob periodicCheckViewJob
public static OakViewChecker testConstructor(org.apache.sling.settings.SlingSettingsService slingSettingsService, org.apache.sling.api.resource.ResourceResolverFactory resourceResolverFactory, org.apache.sling.discovery.base.connectors.ping.ConnectorRegistry connectorRegistry, org.apache.sling.discovery.base.connectors.announcement.AnnouncementRegistry announcementRegistry, org.apache.sling.commons.scheduler.Scheduler scheduler, Config config)
protected org.apache.sling.discovery.base.connectors.announcement.AnnouncementRegistry getAnnouncementRegistry()
getAnnouncementRegistry
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected org.apache.sling.discovery.base.connectors.BaseConfig getConnectorConfig()
getConnectorConfig
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected org.apache.sling.discovery.base.connectors.ping.ConnectorRegistry getConnectorRegistry()
getConnectorRegistry
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected org.apache.sling.api.resource.ResourceResolverFactory getResourceResolverFactory()
getResourceResolverFactory
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected org.apache.sling.commons.scheduler.Scheduler getScheduler()
getScheduler
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected org.apache.sling.settings.SlingSettingsService getSlingSettingsService()
getSlingSettingsService
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected void doActivate()
doActivate
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected void deactivate()
deactivate
in class org.apache.sling.discovery.base.commons.BaseViewChecker
public void initialize(OakDiscoveryService discoveryService)
public boolean resetLeaderElectionId()
protected void doCheckView()
doCheckView
in class org.apache.sling.discovery.base.commons.BaseViewChecker
protected void updateProperties()
updateProperties
in class org.apache.sling.discovery.base.commons.BaseViewChecker
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.