Package com.atlassian.diagnostics.internal.ipd

Class DefaultIpdJobRunner

java.lang.Object

com.atlassian.diagnostics.internal.ipd.DefaultIpdJobRunner

All Implemented Interfaces:

IpdJobRegistry, IpdJobRunner

public class DefaultIpdJobRunner
extends Object
implements IpdJobRunner, IpdJobRegistry

Provides default implementation of IpdJobRunner interface. Product must extend it and implement at least one method isIpdFeatureFlagEnabled();

Since:

2.2.0

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Class<?>,IpdJobRegistration>	jobs

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultIpdJobRunner(CachedIpdState cachedIpdState)

Method Summary

Modifier and Type	Method	Description
void	register(IpdJobRegistration jobRegistration)
void	register(IpdJob job, String key)
void	runJobs()
void	shutdown()
void	unregister(Class<? extends IpdJob> jobClass)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.diagnostics.ipd.api.jobs.IpdJobRegistry

unregister

Field Details

jobs

protected final Map<Class<?>,IpdJobRegistration> jobs

Constructor Details

DefaultIpdJobRunner

protected DefaultIpdJobRunner(CachedIpdState cachedIpdState)

Method Details

register

public void register(@Nonnull
 IpdJob job,
 @Nonnull
 String key)

Specified by:

register in interface IpdJobRegistry

register

public void register(@Nonnull
 IpdJobRegistration jobRegistration)

Specified by:

register in interface IpdJobRegistry

unregister

public void unregister(@Nonnull
 Class<? extends IpdJob> jobClass)

Specified by:

unregister in interface IpdJobRegistry

runJobs

public void runJobs()
             throws InterruptedException

Specified by:

runJobs in interface IpdJobRunner

Throws:

InterruptedException

shutdown

public void shutdown()

Specified by:

shutdown in interface IpdJobRegistry