com.mulesoft.mule.runtime.module.batch.internal.engine.history

Class DefaultHistoryExpirationMonitor

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.engine.history.DefaultHistoryExpirationMonitor

All Implemented Interfaces:

HistoryExpirationMonitor, Runnable

public class DefaultHistoryExpirationMonitor
extends Object
implements HistoryExpirationMonitor, Runnable

Default implementation of HistoryExpirationMonitor

This implementation is based on one single thread which runs on a given frequency.

Since:

3.8.0

Constructor Summary

Constructors

Constructor and Description
DefaultHistoryExpirationMonitor(BatchEngine batchEngine, BatchJobInstanceStore store, long frequency, TimeUnit timeUnit, org.mule.runtime.core.api.MuleContext muleContext)

Method Summary

Modifier and Type	Method and Description
void	beginMonitoring() Begins monitoring and disposal of historic job instances
void	run()
void	stopMonitoring() Shutdowns the scheduler that executes the expiration tasks.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultHistoryExpirationMonitor

public DefaultHistoryExpirationMonitor(BatchEngine batchEngine,
                                       BatchJobInstanceStore store,
                                       long frequency,
                                       TimeUnit timeUnit,
                                       org.mule.runtime.core.api.MuleContext muleContext)

Method Detail

beginMonitoring

public void beginMonitoring()

Description copied from interface: HistoryExpirationMonitor

Begins monitoring and disposal of historic job instances

Specified by:

beginMonitoring in interface HistoryExpirationMonitor

run

public void run()

Specified by:

run in interface Runnable

stopMonitoring

public void stopMonitoring()

Shutdowns the scheduler that executes the expiration tasks. It waits up to 30 seconds for it to shutdown and it throws a MuleException if it could not be stopped

Specified by:

stopMonitoring in interface HistoryExpirationMonitor

toString

public String toString()

Overrides:

toString in class Object