|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.jboss.mx.util.JBossNotificationBroadcasterSupport
org.jboss.system.ServiceMBeanSupport
org.jboss.mq.pm.none.PersistenceManager
A persistence manager and cache store that does not persistence. It can do persistence by delegating to a real persistence manager, depending upon destination configuration.
| Field Summary |
| Fields inherited from class org.jboss.system.ServiceMBeanSupport |
log, server, SERVICE_CONTROLLER_SIG, serviceName |
| Fields inherited from interface org.jboss.system.ServiceMBean |
CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED |
| Fields inherited from interface org.jboss.mq.pm.PersistenceManagerMBean |
OBJECT_NAME |
| Constructor Summary | |
PersistenceManager()
|
|
| Method Summary | |
void |
add(MessageReference message,
Tx txId)
Add a message to the persistent store. |
void |
closeQueue(JMSDestination jmsDest,
SpyDestination dest)
Close a queue |
void |
commitPersistentTx(Tx txId)
Commit the transaction to the persistent store. |
Tx |
createPersistentTx()
Create and return a unique transaction id. |
javax.management.ObjectName |
getDelegatePM()
Retrieve the delegate persistence manager |
Object |
getInstance()
Get the persistence manager instance |
javax.management.ObjectName |
getMessageCache()
Unsupported operation |
MessageCache |
getMessageCacheInstance()
Get the message cache |
TxManager |
getTxManager()
Get a transaction manager. |
SpyMessage |
loadFromStorage(MessageReference mh)
Reads the message refered to by the MessagReference back as a SpyMessage |
void |
remove(MessageReference message,
Tx txId)
Remove message from the persistent store. |
void |
removeFromStorage(MessageReference mh)
Removes the message that was stored in secondary storage. |
void |
restoreQueue(JMSDestination jmsDest,
SpyDestination dest)
Restore a queue. |
void |
rollbackPersistentTx(Tx txId)
Rollback the transaction. |
void |
saveToStorage(MessageReference mh,
SpyMessage message)
Stores the given message to secondary storeage. |
void |
setDelegatePM(javax.management.ObjectName delegateName)
Set the delegate persistence manager |
void |
setMessageCache(javax.management.ObjectName messageCache)
Unsupported operation |
protected void |
startService()
|
void |
update(MessageReference message,
Tx txId)
Update message in the persistent store. |
| Methods inherited from class org.jboss.system.ServiceMBeanSupport |
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 |
addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Methods inherited from interface org.jboss.system.ServiceMBean |
getName, getState, getStateString, jbossInternalLifecycle |
| Methods inherited from interface org.jboss.system.Service |
create, destroy, start, stop |
| Constructor Detail |
public PersistenceManager()
| Method Detail |
public javax.management.ObjectName getDelegatePM()
getDelegatePM in interface PersistenceManagerMBeanpublic void setDelegatePM(javax.management.ObjectName delegateName)
setDelegatePM in interface PersistenceManagerMBeanpublic void add(MessageReference message, Tx txId) throws javax.jms.JMSException
PersistenceManager
add in interface PersistenceManagermessage - the messagetxId - the transaction
javax.jms.JMSException - for any errorpublic void closeQueue(JMSDestination jmsDest, SpyDestination dest) throws javax.jms.JMSException
PersistenceManager
closeQueue in interface PersistenceManagerjmsDest - the jms destinationdest - the client destination
javax.jms.JMSException - for any errorpublic void commitPersistentTx(Tx txId) throws javax.jms.JMSException
PersistenceManager
commitPersistentTx in interface PersistenceManagertxId - Description of Parameter
javax.jms.JMSException - for any errorpublic Tx createPersistentTx() throws javax.jms.JMSException
PersistenceManager
createPersistentTx in interface PersistenceManagerjavax.jms.JMSException - for any errorpublic MessageCache getMessageCacheInstance()
PersistenceManager
getMessageCacheInstance in interface PersistenceManagerpublic TxManager getTxManager()
PersistenceManager
getTxManager in interface PersistenceManagerpublic void remove(MessageReference message, Tx txId) throws javax.jms.JMSException
PersistenceManager
remove in interface PersistenceManagermessage - the messagetxId - the transaction
javax.jms.JMSException - for any errorpublic void restoreQueue(JMSDestination jmsDest, SpyDestination dest) throws javax.jms.JMSException
PersistenceManager
restoreQueue in interface PersistenceManagerjmsDest - the jms destinationdest - the client destination
javax.jms.JMSException - for any errorpublic void rollbackPersistentTx(Tx txId) throws javax.jms.JMSException
PersistenceManager
rollbackPersistentTx in interface PersistenceManagertxId - Description of Parameter
javax.jms.JMSException - for any errorpublic void update(MessageReference message, Tx txId) throws javax.jms.JMSException
PersistenceManager
update in interface PersistenceManagermessage - txId - Description of Parameter
javax.jms.JMSException - for any errorpublic Object getInstance()
PersistenceManagerMBean
getInstance in interface PersistenceManagerMBeanpublic javax.management.ObjectName getMessageCache()
getMessageCache in interface PersistenceManagerMBeanpublic void setMessageCache(javax.management.ObjectName messageCache)
setMessageCache in interface PersistenceManagerMBeanmessageCache - the object namepublic SpyMessage loadFromStorage(MessageReference mh) throws javax.jms.JMSException
CacheStore
loadFromStorage in interface CacheStoremh - the message reference
javax.jms.JMSException - for any errorpublic void removeFromStorage(MessageReference mh) throws javax.jms.JMSException
CacheStore
removeFromStorage in interface CacheStoremh - the message reference
javax.jms.JMSException - for any errorpublic void saveToStorage(MessageReference mh, SpyMessage message) throws javax.jms.JMSException
CacheStore
saveToStorage in interface CacheStoremh - the message referencemessage - the message
javax.jms.JMSException - for any error
protected void startService()
throws Exception
Exception
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||