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

Modifier and Type	Field and Description
static org.jboss.msc.service.ServiceName	SERVICE_NAME

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

NULL, NULL_VALUE

Constructor Summary

Constructors

Constructor and Description
FileTimerPersistence(boolean createIfNotExists)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTimer(TimerEntity timerEntity) Called when a timer is being persisted
org.jboss.msc.value.InjectedValue<String>	getBaseDir()
org.jboss.msc.value.InjectedValue<org.jboss.modules.ModuleLoader>	getModuleLoader()
org.jboss.msc.value.InjectedValue<TransactionManager>	getTransactionManager()
org.jboss.msc.value.InjectedValue<TransactionSynchronizationRegistry>	getTransactionSynchronizationRegistry()
FileTimerPersistence	getValue()
List<TimerEntity>	loadActiveTimers(String timedObjectId) Load all active timers for the given object.
List<TimerEntity>	loadActiveTimers(String timedObjectId, Object primaryKey) Load all active timers for the given entity bean with the given primary key
TimerEntity	loadTimer(String id, String timedObjectId) Load a timer from persistent storage
void	persistTimer(TimerEntity timerEntity) 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

Field Detail

SERVICE_NAME

public static final org.jboss.msc.service.ServiceName SERVICE_NAME

Constructor Detail

FileTimerPersistence

public FileTimerPersistence(boolean createIfNotExists)

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(TimerEntity timerEntity)

Description copied from interface: TimerPersistence

Called when a timer is being persisted

Specified by:

addTimer in interface TimerPersistence

persistTimer

public void persistTimer(TimerEntity timerEntity)

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

loadTimer

public TimerEntity loadTimer(String id,
                    String timedObjectId)

Description copied from interface: TimerPersistence

Load a timer from persistent storage

Specified by:

loadTimer in interface TimerPersistence

Returns:

loadActiveTimers

public List<TimerEntity> loadActiveTimers(String timedObjectId,
                                 Object primaryKey)

Description copied from interface: TimerPersistence

Load all active timers for the given entity bean with the given primary key

Specified by:

loadActiveTimers in interface TimerPersistence

Parameters:

timedObjectId - The timed object id to load timers for

primaryKey - The primary key of the entity bean, or null for all timers

Returns:

A list of all active timers

loadActiveTimers

public List<TimerEntity> loadActiveTimers(String timedObjectId)

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()

getBaseDir

public org.jboss.msc.value.InjectedValue<String> getBaseDir()