|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.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 DatabasePersistencePluginSQLException
public void createTableIfNotExists()
throws SQLException
createTableIfNotExists in interface DatabasePersistencePluginSQLExceptionpublic void insertTimer(String timerId, TimedObjectId timedObjectId, Date initialExpiration, long intervalDuration, Serializable info) throws SQLException
insertTimer in interface DatabasePersistencePluginSQLExceptionpublic List selectTimers() throws SQLException
selectTimers in interface DatabasePersistencePluginSQLExceptionpublic void deleteTimer(String timerId, TimedObjectId timedObjectId) throws SQLException
deleteTimer in interface DatabasePersistencePluginSQLException
public void clearTimers()
throws SQLException
clearTimers in interface DatabasePersistencePluginSQLExceptionpublic String getTableName()
getTableName in interface DatabasePersistencePluginpublic String getColumnTimerID()
getColumnTimerID in interface DatabasePersistencePluginpublic String getColumnTargetID()
getColumnTargetID in interface DatabasePersistencePluginpublic String getColumnInitialDate()
getColumnInitialDate in interface DatabasePersistencePluginpublic String getColumnTimerInterval()
getColumnTimerInterval in interface DatabasePersistencePluginpublic String getColumnInstancePK()
getColumnInstancePK in interface DatabasePersistencePluginpublic String getColumnInfo()
getColumnInfo in interface DatabasePersistencePluginprotected 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 | ||||||||||