|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.ejb.txtimer.GeneralPurposeDatabasePersistencePlugin
This DatabasePersistencePlugin uses getBytes/setBytes to persist the serializable objects associated with the timer.
Field Summary | |
protected javax.management.ObjectName |
dataSourceName
|
protected DataSource |
ds
|
protected javax.management.ObjectName |
metaDataName
|
protected javax.management.MBeanServer |
server
|
Constructor Summary | |
GeneralPurposeDatabasePersistencePlugin()
|
Method Summary | |
void |
clearTimers()
Clear all persisted timers |
void |
createTableIfNotExists()
Create the timer table if it does not exist already |
void |
deleteTimer(String timerId,
TimedObjectId timedObjectId)
Delete a timer. |
protected Object |
deserialize(byte[] bytes)
Deserialize an object |
protected Object |
deserialize(InputStream input)
Deserialize an object |
String |
getColumnInfo()
Get the info column name |
String |
getColumnInitialDate()
Get the initial date column name |
String |
getColumnInstancePK()
Get the instance PK column name |
String |
getColumnTargetID()
Get the target ID column name |
String |
getColumnTimerID()
Get the timer ID column name |
String |
getColumnTimerInterval()
Get the timer interval column name |
String |
getTableName()
Get the timer table name |
void |
init(javax.management.MBeanServer server,
javax.management.ObjectName dataSourceName)
Initialize the plugin |
void |
insertTimer(String timerId,
TimedObjectId timedObjectId,
Date initialExpiration,
long intervalDuration,
Serializable info)
Insert a timer object |
List |
selectTimers()
Select a list of currently persisted timer handles |
protected byte[] |
serialize(Object obj)
Serialize an object |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected javax.management.ObjectName dataSourceName
protected javax.management.MBeanServer server
protected DataSource ds
protected javax.management.ObjectName metaDataName
Constructor Detail |
public GeneralPurposeDatabasePersistencePlugin()
Method Detail |
public void init(javax.management.MBeanServer server, javax.management.ObjectName dataSourceName) throws SQLException
init
in interface DatabasePersistencePlugin
SQLException
public void createTableIfNotExists() throws SQLException
createTableIfNotExists
in interface DatabasePersistencePlugin
SQLException
public void insertTimer(String timerId, TimedObjectId timedObjectId, Date initialExpiration, long intervalDuration, Serializable info) throws SQLException
insertTimer
in interface DatabasePersistencePlugin
SQLException
public List selectTimers() throws SQLException
selectTimers
in interface DatabasePersistencePlugin
SQLException
public void deleteTimer(String timerId, TimedObjectId timedObjectId) throws SQLException
deleteTimer
in interface DatabasePersistencePlugin
SQLException
public void clearTimers() throws SQLException
clearTimers
in interface DatabasePersistencePlugin
SQLException
public String getTableName()
getTableName
in interface DatabasePersistencePlugin
public String getColumnTimerID()
getColumnTimerID
in interface DatabasePersistencePlugin
public String getColumnTargetID()
getColumnTargetID
in interface DatabasePersistencePlugin
public String getColumnInitialDate()
getColumnInitialDate
in interface DatabasePersistencePlugin
public String getColumnTimerInterval()
getColumnTimerInterval
in interface DatabasePersistencePlugin
public String getColumnInstancePK()
getColumnInstancePK
in interface DatabasePersistencePlugin
public String getColumnInfo()
getColumnInfo
in interface DatabasePersistencePlugin
protected byte[] serialize(Object obj)
protected Object deserialize(byte[] bytes)
protected Object deserialize(InputStream input)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |