public class ProductionTimerDrivenModuleManager extends BaseModuleManager<TimerDrivenModuleMetadata,TimerDrivenModule> implements TimerDrivenModuleManager
TimerDrivenModuleManager. Must be backed by a GraphDatabaseService,
as there is no support for using TimerDrivenModules in batch mode (i.e. with org.neo4j.unsafe.batchinsert.BatchInserters).metadataRepository, modules| Constructor and Description |
|---|
ProductionTimerDrivenModuleManager(org.neo4j.graphdb.GraphDatabaseService database,
ModuleMetadataRepository metadataRepository,
TimingStrategy timingStrategy,
StatsCollector statsCollector)
Constructs a new
ProductionTimerDrivenModuleManager based on the given arguments. |
| Modifier and Type | Method and Description |
|---|---|
protected TimerDrivenModuleMetadata |
acknowledgeMetadata(TimerDrivenModule module,
TimerDrivenModuleMetadata metadata)
Acknowledge module metadata after it has been created afresh or successfully loaded from a
ModuleMetadataRepository. |
protected TimerDrivenModuleMetadata |
createFreshMetadata(TimerDrivenModule module)
Create new metadata for a module.
|
void |
shutdownModules()
Bring all modules to an orderly shutdown, when the database is stopped.
|
void |
startModules()
Perform work needed to make modules start doing their job.
|
checkNotAlreadyRegistered, cleanupMetadata, getModule, getModule, handleCorruptMetadata, handleNoMetadata, loadMetadata, registerModuleclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcheckNotAlreadyRegistered, cleanupMetadata, getModule, getModule, loadMetadata, registerModulepublic ProductionTimerDrivenModuleManager(org.neo4j.graphdb.GraphDatabaseService database,
ModuleMetadataRepository metadataRepository,
TimingStrategy timingStrategy,
StatsCollector statsCollector)
ProductionTimerDrivenModuleManager based on the given arguments.database - storing graph data.metadataRepository - for storing module metadata.timingStrategy - the TimingStrategy to use for scheduling the timer-driven modules.protected TimerDrivenModuleMetadata createFreshMetadata(TimerDrivenModule module)
createFreshMetadata in class BaseModuleManager<TimerDrivenModuleMetadata,TimerDrivenModule>module - for which to create metadata.protected TimerDrivenModuleMetadata acknowledgeMetadata(TimerDrivenModule module, TimerDrivenModuleMetadata metadata)
ModuleMetadataRepository.
The implementation can, for example, choose to let the module know about its own metadata. This method also gives
the subclasses the opportunity to modify the metadata before it is persisted to the database.acknowledgeMetadata in class BaseModuleManager<TimerDrivenModuleMetadata,TimerDrivenModule>module - for which to acknowledge metadata.metadata - to acknowledge.public void startModules()
startModules in interface ModuleManager<TimerDrivenModule>startModules in class BaseModuleManager<TimerDrivenModuleMetadata,TimerDrivenModule>public void shutdownModules()
shutdownModules in interface ModuleManager<TimerDrivenModule>shutdownModules in class BaseModuleManager<TimerDrivenModuleMetadata,TimerDrivenModule>Copyright © 2013-2016–2018 Graph Aware Limited. All rights reserved.