org.dataone.cn.batch.logging

Class LogAggregationScheduleManager

java.lang.Object

org.dataone.cn.batch.logging.LogAggregationScheduleManager

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class LogAggregationScheduleManager
extends Object
implements org.springframework.context.ApplicationContextAware

The bean must be managed by Spring. upon startup of spring it will execute via init method Evaluate whether the NodeList contains nodes that should be harvested for logs. It will add or remove triggers for jobs based on a daily refactoring

Author:

waltz

Constructor Summary

Constructors

Constructor and Description
LogAggregationScheduleManager()

Method Summary

Modifier and Type	Method and Description
static LogAggregationScheduleManager	getInstance()
org.quartz.Scheduler	getScheduler()
SystemMetadataEntryListener	getSystemMetadataEntryListener()
void	init() Called by Spring to bootstrap log aggregation it will set up default intervals between job executions for Membernode harvesting it will initialize Quartz it will schedule membernodes for harvesting it also adds a listener for changes in the hazelcast Nodes map and hz partitioner Change in hzNodes or migration of partitions may entail rebalancing of quartz jobs
void	scheduleHarvest() will perform the initial calculation or the recalculation of the scheduler.
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setScheduler(org.quartz.Scheduler scheduler)
void	setSystemMetadataEntryListener(SystemMetadataEntryListener systemMetadataEntryListener)

Methods inherited from class java.lang.Object

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

Constructor Detail

LogAggregationScheduleManager

public LogAggregationScheduleManager()

Method Detail

init

public void init()

Called by Spring to bootstrap log aggregation it will set up default intervals between job executions for Membernode harvesting it will initialize Quartz it will schedule membernodes for harvesting it also adds a listener for changes in the hazelcast Nodes map and hz partitioner Change in hzNodes or migration of partitions may entail rebalancing of quartz jobs

scheduleHarvest

public void scheduleHarvest()
                     throws org.quartz.SchedulerException,
                            org.dataone.service.exceptions.NotImplemented,
                            org.dataone.service.exceptions.ServiceFailure

will perform the initial calculation or the recalculation of the scheduler. if scheduler is running, it will be disabled The jobs to schedule are determined by Collection math based on which if any jobs have already been scheduled and the state of the nodes from listNodes scheduleHarvest is called by a quartz job, there is a possibility of concurrent execution of the method, therefore the call is synchronized

Throws:

org.quartz.SchedulerException

org.dataone.service.exceptions.NotImplemented

org.dataone.service.exceptions.ServiceFailure

getScheduler

public org.quartz.Scheduler getScheduler()

setScheduler

public void setScheduler(org.quartz.Scheduler scheduler)

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

getSystemMetadataEntryListener

public SystemMetadataEntryListener getSystemMetadataEntryListener()

setSystemMetadataEntryListener

public void setSystemMetadataEntryListener(SystemMetadataEntryListener systemMetadataEntryListener)

getInstance

public static LogAggregationScheduleManager getInstance()
                                                 throws Exception

Throws:

Exception