|
||||||||||
PREV CLASS (src) 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.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 (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 | |
void |
add(MessageReference (src) message,
Tx (src) txId)
Add a message to the persistent store. |
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) |
getDelegatePM()
Retrieve the delegate persistence manager |
java.lang.Object |
getInstance()
|
ObjectName (src) |
getMessageCache()
Unsupported operation |
MessageCache (src) |
getMessageCacheInstance()
Get the message cache |
TxManager (src) |
getTxManager()
Get a transaction manager. |
SpyMessage (src) |
loadFromStorage(MessageReference (src) mh)
Reads the message refered to by the MessagReference back as a SpyMessage |
void |
remove(MessageReference (src) message,
Tx (src) txId)
Remove message from the persistent store. |
void |
removeFromStorage(MessageReference (src) mh)
Removes the message that was stored in secondary storage. |
void |
restoreQueue(JMSDestination (src) jmsDest,
SpyDestination (src) dest)
Restore a queue. |
void |
rollbackPersistentTx(Tx (src) txId)
Rollback the transaction. |
void |
saveToStorage(MessageReference (src) mh,
SpyMessage (src) message)
Stores the given message to secondary storeage. |
void |
setDelegatePM(ObjectName (src) delegateName)
Set the delegate persistence manager |
void |
setMessageCache(ObjectName (src) messageCache)
Unsupported operation |
protected void |
startService()
Sub-classes should override this method to provide custum 'start' logic. |
void |
update(MessageReference (src) message,
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()
Method Detail |
public ObjectName (src) getDelegatePM()
public void setDelegatePM(ObjectName (src) delegateName)
public void add(MessageReference (src) message, Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
add
in interface PersistenceManager (src)
message
- the messagetxId
- the transaction
JMSException (src)
- for any errorpublic 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 void commitPersistentTx(Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
commitPersistentTx
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 MessageCache (src) getMessageCacheInstance()
PersistenceManager (src)
getMessageCacheInstance
in interface PersistenceManager (src)
public TxManager (src) getTxManager()
PersistenceManager (src)
getTxManager
in interface PersistenceManager (src)
public void remove(MessageReference (src) message, Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
remove
in interface PersistenceManager (src)
message
- the messagetxId
- the transaction
JMSException (src)
- for any errorpublic 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 rollbackPersistentTx(Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
rollbackPersistentTx
in interface PersistenceManager (src)
txId
- Description of Parameter
JMSException (src)
- for any errorpublic void update(MessageReference (src) message, Tx (src) txId) throws JMSException (src)
PersistenceManager (src)
update
in interface PersistenceManager (src)
message
- txId
- Description of Parameter
JMSException (src)
- for any errorpublic java.lang.Object getInstance()
public ObjectName (src) getMessageCache()
public void setMessageCache(ObjectName (src) messageCache)
public SpyMessage (src) loadFromStorage(MessageReference (src) mh) throws JMSException (src)
CacheStore (src)
loadFromStorage
in interface CacheStore (src)
mh
- the message reference
JMSException (src)
- for any errorpublic void removeFromStorage(MessageReference (src) mh) throws JMSException (src)
CacheStore (src)
removeFromStorage
in interface CacheStore (src)
mh
- the message reference
JMSException (src)
- for any errorpublic void saveToStorage(MessageReference (src) mh, SpyMessage (src) message) throws JMSException (src)
CacheStore (src)
saveToStorage
in interface CacheStore (src)
mh
- the message referencemessage
- the message
JMSException (src)
- for any errorprotected 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
|
||||||||||
PREV CLASS (src) NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |