Package org.alfresco.heartbeat

Class HBDataCollectorServiceImpl

java.lang.Object

org.alfresco.heartbeat.HBDataCollectorServiceImpl

All Implemented Interfaces:

HBDataCollectorService, LicenseService.LicenseChangeHandler

public class HBDataCollectorServiceImpl
extends java.lang.Object
implements HBDataCollectorService, LicenseService.LicenseChangeHandler

HBDataCollectorService implementation. This service manages multiple collectors. The collectors containing cron expression which will be used to create time scheduled jobs for executing the tasks from the collector

Constructor Summary

Constructors

Constructor	Description
HBDataCollectorServiceImpl(boolean defaultHeartBeatState)

Method Summary

Modifier and Type	Method	Description
void	deregisterCollector(HBBaseDataCollector collector)	Deregister data collector.
boolean	isEnabled()
boolean	isEnabledByDefault()
void	onLicenseChange(LicenseDescriptor licenseDescriptor)	Listens for license changes.
void	onLicenseFail()	License load failure resets the heartbeat back to the default state
void	registerCollector(HBBaseDataCollector collector)	Register data collector with this service and start the schedule.
void	setHbDataSenderService(org.alfresco.heartbeat.datasender.HBDataSenderService hbDataSenderService)
void	setJobLockService(JobLockService jobLockService)
void	setScheduler(org.quartz.Scheduler scheduler)
void	setTestMode(boolean testMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

HBDataCollectorServiceImpl

public HBDataCollectorServiceImpl(boolean defaultHeartBeatState)

Parameters:

defaultHeartBeatState - the default enabled state of heartbeat

Method Detail

setHbDataSenderService

public void setHbDataSenderService(org.alfresco.heartbeat.datasender.HBDataSenderService hbDataSenderService)

setJobLockService

public void setJobLockService(JobLockService jobLockService)

setScheduler

public void setScheduler(org.quartz.Scheduler scheduler)

isEnabled

public boolean isEnabled()

setTestMode

public void setTestMode(boolean testMode)

registerCollector

public void registerCollector(HBBaseDataCollector collector)

Register data collector with this service and start the schedule. The registered collector will be called to provide heartbeat data at the scheduled interval. Each collector registered via this method must have a unique collector id.

Specified by:

registerCollector in interface HBDataCollectorService

Parameters:

collector - collector to register

deregisterCollector

public void deregisterCollector(HBBaseDataCollector collector)

Deregister data collector. Before the collector will be removed the collector job will be unscheduled

Specified by:

deregisterCollector in interface HBDataCollectorService

Parameters:

collector -

isEnabledByDefault

public boolean isEnabledByDefault()

Specified by:

isEnabledByDefault in interface HBDataCollectorService

onLicenseChange

public void onLicenseChange(LicenseDescriptor licenseDescriptor)

Listens for license changes. If a license is change or removed, the heartbeat job is rescheduled.

Specified by:

onLicenseChange in interface LicenseService.LicenseChangeHandler

Parameters:

licenseDescriptor - the new license (never null)

onLicenseFail

public void onLicenseFail()

License load failure resets the heartbeat back to the default state

Specified by:

onLicenseFail in interface LicenseService.LicenseChangeHandler