org.jboss.as.ejb3.timerservice.persistence.database

Class DatabaseTimerPersistence

java.lang.Object

org.jboss.as.ejb3.timerservice.persistence.database.DatabaseTimerPersistence

All Implemented Interfaces:

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

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

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
DatabaseTimerPersistence(String name, String database, String partition)

Method Summary

Modifier and Type	Method and Description
void	addTimer(TimerImpl timerEntity) Called when a timer is being persisted
Object	deSerialize(String data)
org.jboss.msc.value.InjectedValue<ManagedReferenceFactory>	getDataSourceInjectedValue()
org.jboss.msc.value.InjectedValue<org.jboss.modules.ModuleLoader>	getModuleLoader()
DatabaseTimerPersistence	getValue()
List<TimerImpl>	loadActiveTimers(String timedObjectId, TimerServiceImpl timerService) Load all active timers for the given object.
void	persistTimer(TimerImpl 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

Constructor Detail

DatabaseTimerPersistence

public DatabaseTimerPersistence(String name,
                                String database,
                                String partition)

Method Detail

start

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

Specified by:

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

Throws:

org.jboss.msc.service.StartException

stop

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

Specified by:

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

addTimer

public void addTimer(TimerImpl timerEntity)

Description copied from interface: TimerPersistence

Called when a timer is being persisted

Specified by:

addTimer in interface TimerPersistence

persistTimer

public void persistTimer(TimerImpl 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

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

getValue

public DatabaseTimerPersistence getValue()
                                  throws IllegalStateException,
                                         IllegalArgumentException

Specified by:

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

Throws:

IllegalStateException

IllegalArgumentException

deSerialize

public Object deSerialize(String data)
                   throws SQLException

Throws:

SQLException

getDataSourceInjectedValue

public org.jboss.msc.value.InjectedValue<ManagedReferenceFactory> getDataSourceInjectedValue()

getModuleLoader

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