|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.mx.util.JBossNotificationBroadcasterSupport (src)
org.jboss.system.ServiceMBeanSupport (src)
org.jboss.mq.pm.jdbc2.PersistenceManager
This class manages all persistence related services for JDBC based persistence.
Field Summary |
Fields inherited from class org.jboss.system.ServiceMBeanSupport (src) |
log, server, SERVICE_CONTROLLER_SIG, serviceName |
Fields inherited from interface org.jboss.system.ServiceMBean (src) |
CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED |
Constructor Summary | |
PersistenceManager()
|
Method Summary | |
protected void |
add(java.sql.Connection c,
java.lang.String queue,
SpyMessage (src) message,
Tx (src) txId,
java.lang.String mark)
|
void |
add(MessageReference (src) messageRef,
Tx (src) txId)
Add a message to the persistent store. |
void |
addTXRecord(java.sql.Connection c,
long txid)
|
void |
closeQueue(JMSDestination (src) jmsDest,
SpyDestination (src) dest)
Close a queue |
void |
commitPersistentTx(Tx (src) txId)
Commit the transaction to the persistent store. |
Tx (src) |
createPersistentTx()
Create and return a unique transaction id. |
ObjectName (src) |
getConnectionManager()
|
int |
getConnectionRetryAttempts()
Gets the ConnectionRetryAttempts. |
java.lang.Object |
getInstance()
Describe getInstance method here. |
ObjectName (src) |
getMessageCache()
Describe getMessageCache method here. |
MessageCache (src) |
getMessageCacheInstance()
Get the message cache |
java.lang.String |
getSqlProperties()
Gets the sqlProperties. |
TxManager (src) |
getTxManager()
Get a transaction manager. |
void |
insertPersistentTx(org.jboss.mq.pm.jdbc2.PersistenceManager.TransactionManagerStrategy tms,
java.sql.Connection c,
Tx (src) tx)
|
SpyMessage (src) |
loadFromStorage(MessageReference (src) messageRef)
Reads the message refered to by the MessagReference back as a SpyMessage |
void |
markMessage(java.sql.Connection c,
long messageid,
java.lang.String destination,
Tx (src) txId,
java.lang.String mark)
|
void |
remove(MessageReference (src) messageRef,
Tx (src) txId)
Remove message from the persistent store. |
void |
removeFromStorage(MessageReference (src) messageRef)
Removes the message that was stored in secondary storage. |
void |
removeMarkedMessages(java.sql.Connection c,
Tx (src) txid,
java.lang.String mark)
|
void |
removeTXRecord(java.sql.Connection c,
long txid)
|
void |
resolveAllUncommitedTXs()
|
void |
restoreQueue(JMSDestination (src) jmsDest,
SpyDestination (src) dest)
Restore a queue. |
void |
rollbackPersistentTx(Tx (src) txId)
Rollback the transaction. |
void |
saveToStorage(MessageReference (src) messageRef,
SpyMessage (src) message)
Stores the given message to secondary storeage. |
void |
setBlob(java.sql.PreparedStatement stmt,
int column,
SpyMessage (src) message)
|
void |
setConnectionManager(ObjectName (src) connectionManagerName)
|
void |
setConnectionRetryAttempts(int value)
Sets the ConnectionRetryAttempts. |
void |
setMessageCache(ObjectName (src) messageCache)
Describe setMessageCache method here. |
void |
setSqlProperties(java.lang.String value)
Sets the sqlProperties. |
void |
startService()
Sub-classes should override this method to provide custum 'start' logic. |
void |
update(MessageReference (src) messageRef,
Tx (src) txId)
Update message in the persistent store. |
Methods inherited from class org.jboss.system.ServiceMBeanSupport (src) |
create, createService, destroy, destroyService, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, stop, stopService |
Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport (src) |
addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public PersistenceManager() throws JMSException (src)
Method Detail |
public void resolveAllUncommitedTXs() throws JMSException (src)
JMSException (src)
public void restoreQueue(JMSDestination (src) jmsDest, SpyDestination (src) dest) throws JMSException (src)
PersistenceManager (src)
restoreQueue
in interface PersistenceManager (src)
jmsDest
- the jms destinationdest
- the client destination
JMSException (src)
- for any errorpublic void commitPersistentTx(Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
commitPersistentTx
in interface PersistenceManager (src)
txId
- Description of Parameter
JMSException (src)
- for any errorpublic void removeMarkedMessages(java.sql.Connection c, Tx (src) txid, java.lang.String mark) throws java.sql.SQLException
java.sql.SQLException
public void addTXRecord(java.sql.Connection c, long txid) throws java.sql.SQLException
java.sql.SQLException
public void removeTXRecord(java.sql.Connection c, long txid) throws java.sql.SQLException
java.sql.SQLException
public void rollbackPersistentTx(Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
rollbackPersistentTx
in interface PersistenceManager (src)
txId
- Description of Parameter
JMSException (src)
- for any errorpublic Tx (src) createPersistentTx() throws JMSException (src)
PersistenceManager (src)
createPersistentTx
in interface PersistenceManager (src)
JMSException (src)
- for any errorpublic void insertPersistentTx(org.jboss.mq.pm.jdbc2.PersistenceManager.TransactionManagerStrategy tms, java.sql.Connection c, Tx (src) tx) throws JMSException (src)
JMSException (src)
public void add(MessageReference (src) messageRef, Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
add
in interface PersistenceManager (src)
messageRef
- the messagetxId
- the transaction
JMSException (src)
- for any errorprotected void add(java.sql.Connection c, java.lang.String queue, SpyMessage (src) message, Tx (src) txId, java.lang.String mark) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
public void markMessage(java.sql.Connection c, long messageid, java.lang.String destination, Tx (src) txId, java.lang.String mark) throws java.sql.SQLException
java.sql.SQLException
public void setBlob(java.sql.PreparedStatement stmt, int column, SpyMessage (src) message) throws java.io.IOException, java.sql.SQLException
java.io.IOException
java.sql.SQLException
public void update(MessageReference (src) messageRef, Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
update
in interface PersistenceManager (src)
messageRef
- txId
- Description of Parameter
JMSException (src)
- for any errorpublic void remove(MessageReference (src) messageRef, Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
remove
in interface PersistenceManager (src)
messageRef
- the messagetxId
- the transaction
JMSException (src)
- for any errorpublic TxManager (src) getTxManager()
PersistenceManager (src)
getTxManager
in interface PersistenceManager (src)
public void closeQueue(JMSDestination (src) jmsDest, SpyDestination (src) dest) throws JMSException (src)
PersistenceManager (src)
closeQueue
in interface PersistenceManager (src)
jmsDest
- the jms destinationdest
- the client destination
JMSException (src)
- for any errorpublic SpyMessage (src) loadFromStorage(MessageReference (src) messageRef) throws JMSException (src)
CacheStore (src)
loadFromStorage
in interface CacheStore (src)
messageRef
- the message reference
JMSException (src)
- for any errorpublic void removeFromStorage(MessageReference (src) messageRef) throws JMSException (src)
CacheStore (src)
removeFromStorage
in interface CacheStore (src)
messageRef
- the message reference
JMSException (src)
- for any errorpublic void saveToStorage(MessageReference (src) messageRef, SpyMessage (src) message) throws JMSException (src)
CacheStore (src)
saveToStorage
in interface CacheStore (src)
messageRef
- the message referencemessage
- the message
JMSException (src)
- for any errorpublic void startService() throws java.lang.Exception
ServiceMBeanSupport (src)
This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.
startService
in class ServiceMBeanSupport (src)
java.lang.Exception
public java.lang.Object getInstance()
getInstance
method here.
Object
valuepublic ObjectName (src) getMessageCache()
getMessageCache
method here.
ObjectName
valuepublic void setMessageCache(ObjectName (src) messageCache)
setMessageCache
method here.
messageCache
- an ObjectName
valuepublic ObjectName (src) getConnectionManager()
public void setConnectionManager(ObjectName (src) connectionManagerName)
public MessageCache (src) getMessageCacheInstance()
PersistenceManager (src)
getMessageCacheInstance
in interface PersistenceManager (src)
public java.lang.String getSqlProperties()
public void setSqlProperties(java.lang.String value)
public void setConnectionRetryAttempts(int value)
public int getConnectionRetryAttempts()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |