|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.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 PersistenceManagerMBean
public void setDelegatePM(javax.management.ObjectName delegateName)
setDelegatePM
in interface PersistenceManagerMBean
public void add(MessageReference message, Tx txId) throws javax.jms.JMSException
PersistenceManager
add
in interface PersistenceManager
message
- the messagetxId
- the transaction
javax.jms.JMSException
- for any errorpublic void closeQueue(JMSDestination jmsDest, SpyDestination dest) throws javax.jms.JMSException
PersistenceManager
closeQueue
in interface PersistenceManager
jmsDest
- the jms destinationdest
- the client destination
javax.jms.JMSException
- for any errorpublic void commitPersistentTx(Tx txId) throws javax.jms.JMSException
PersistenceManager
commitPersistentTx
in interface PersistenceManager
txId
- Description of Parameter
javax.jms.JMSException
- for any errorpublic Tx createPersistentTx() throws javax.jms.JMSException
PersistenceManager
createPersistentTx
in interface PersistenceManager
javax.jms.JMSException
- for any errorpublic MessageCache getMessageCacheInstance()
PersistenceManager
getMessageCacheInstance
in interface PersistenceManager
public TxManager getTxManager()
PersistenceManager
getTxManager
in interface PersistenceManager
public void remove(MessageReference message, Tx txId) throws javax.jms.JMSException
PersistenceManager
remove
in interface PersistenceManager
message
- the messagetxId
- the transaction
javax.jms.JMSException
- for any errorpublic void restoreQueue(JMSDestination jmsDest, SpyDestination dest) throws javax.jms.JMSException
PersistenceManager
restoreQueue
in interface PersistenceManager
jmsDest
- the jms destinationdest
- the client destination
javax.jms.JMSException
- for any errorpublic void rollbackPersistentTx(Tx txId) throws javax.jms.JMSException
PersistenceManager
rollbackPersistentTx
in interface PersistenceManager
txId
- Description of Parameter
javax.jms.JMSException
- for any errorpublic void update(MessageReference message, Tx txId) throws javax.jms.JMSException
PersistenceManager
update
in interface PersistenceManager
message
- txId
- Description of Parameter
javax.jms.JMSException
- for any errorpublic Object getInstance()
PersistenceManagerMBean
getInstance
in interface PersistenceManagerMBean
public javax.management.ObjectName getMessageCache()
getMessageCache
in interface PersistenceManagerMBean
public void setMessageCache(javax.management.ObjectName messageCache)
setMessageCache
in interface PersistenceManagerMBean
messageCache
- the object namepublic SpyMessage loadFromStorage(MessageReference mh) throws javax.jms.JMSException
CacheStore
loadFromStorage
in interface CacheStore
mh
- the message reference
javax.jms.JMSException
- for any errorpublic void removeFromStorage(MessageReference mh) throws javax.jms.JMSException
CacheStore
removeFromStorage
in interface CacheStore
mh
- the message reference
javax.jms.JMSException
- for any errorpublic void saveToStorage(MessageReference mh, SpyMessage message) throws javax.jms.JMSException
CacheStore
saveToStorage
in interface CacheStore
mh
- the message referencemessage
- the message
javax.jms.JMSException
- for any errorprotected void startService() throws Exception
Exception
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |