org.jboss.as.ejb3.timerservice.persistence.filestore

Class FileTimerPersistence

java.lang.Object

org.jboss.as.ejb3.timerservice.persistence.filestore.FileTimerPersistence

All Implemented Interfaces:

TimerPersistence, org.jboss.msc.service.Service<FileTimerPersistence>, org.jboss.msc.value.Value<FileTimerPersistence>

public class FileTimerPersistence
extends Object
implements TimerPersistence, org.jboss.msc.service.Service<FileTimerPersistence>

File based persistent timer store.

TODO: this is fairly hackey at the moment, it should be registered as an XA resource to support proper XA semantics

Author:

Stuart Douglas

Field Summary

Fields inherited from interface org.jboss.as.ejb3.timerservice.persistence.TimerPersistence

SERVICE_NAME

Fields inherited from interface org.jboss.msc.service.Service

NULL, NULL_VALUE

Constructor Summary

Constructors

Constructor and Description
FileTimerPersistence(boolean createIfNotExists, String path, String pathRelativeTo)

Method Summary

Modifier and Type	Method and Description
void	addTimer(TimerImpl TimerImpl) Called when a timer is being persisted
org.jboss.msc.value.InjectedValue<org.jboss.modules.ModuleLoader>	getModuleLoader()
org.jboss.msc.value.InjectedValue<PathManager>	getPathManager()
org.jboss.msc.value.InjectedValue<TransactionManager>	getTransactionManager()
org.jboss.msc.value.InjectedValue<TransactionSynchronizationRegistry>	getTransactionSynchronizationRegistry()
FileTimerPersistence	getValue()
List<TimerImpl>	loadActiveTimers(String timedObjectId, TimerServiceImpl timerService) Load all active timers for the given object.
void	persistTimer(TimerImpl TimerImpl) Called when a timer is being persisted
void	start(org.jboss.msc.service.StartContext context)
void	stop(org.jboss.msc.service.StopContext context)
void	timerUndeployed(String timedObjectId) Signals that a timer is being undeployed, and all cached data relating to this object should be dropped to prevent a class loader leak

Methods inherited from class java.lang.Object

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

Constructor Detail

FileTimerPersistence

public FileTimerPersistence(boolean createIfNotExists,
                            String path,
                            String pathRelativeTo)

Method Detail

start

public void start(org.jboss.msc.service.StartContext context)

Specified by:

start in interface org.jboss.msc.service.Service<FileTimerPersistence>

stop

public void stop(org.jboss.msc.service.StopContext context)

Specified by:

stop in interface org.jboss.msc.service.Service<FileTimerPersistence>

getValue

public FileTimerPersistence getValue()
                              throws IllegalStateException,
                                     IllegalArgumentException

Specified by:

getValue in interface org.jboss.msc.value.Value<FileTimerPersistence>

Throws:

IllegalStateException

IllegalArgumentException

addTimer

public void addTimer(TimerImpl TimerImpl)

Description copied from interface: TimerPersistence

Called when a timer is being persisted

Specified by:

addTimer in interface TimerPersistence

persistTimer

public void persistTimer(TimerImpl TimerImpl)

Description copied from interface: TimerPersistence

Called when a timer is being persisted

Specified by:

persistTimer in interface TimerPersistence

timerUndeployed

public void timerUndeployed(String timedObjectId)

Description copied from interface: TimerPersistence

Signals that a timer is being undeployed, and all cached data relating to this object should be dropped to prevent a class loader leak

Specified by:

timerUndeployed in interface TimerPersistence

loadActiveTimers

public List<TimerImpl> loadActiveTimers(String timedObjectId,
                                        TimerServiceImpl timerService)

Description copied from interface: TimerPersistence

Load all active timers for the given object. If the object is an entity bean timers for all beans will be returned.

Specified by:

loadActiveTimers in interface TimerPersistence

Parameters:

timedObjectId - The timed object id to load timers for

Returns:

A list of all active timers

getTransactionManager

public org.jboss.msc.value.InjectedValue<TransactionManager> getTransactionManager()

getTransactionSynchronizationRegistry

public org.jboss.msc.value.InjectedValue<TransactionSynchronizationRegistry> getTransactionSynchronizationRegistry()

getModuleLoader

public org.jboss.msc.value.InjectedValue<org.jboss.modules.ModuleLoader> getModuleLoader()

getPathManager

public org.jboss.msc.value.InjectedValue<PathManager> getPathManager()