|
||||||||||
| 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 error
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 error
public void commitPersistentTx(Tx (src) txId)
throws JMSException (src)
PersistenceManager (src)
commitPersistentTx in interface PersistenceManager (src) txId - Description of Parameter
JMSException (src) - for any error
public 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 error
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 error
public void rollbackPersistentTx(Tx (src) txId)
throws JMSException (src)
PersistenceManager (src)
rollbackPersistentTx in interface PersistenceManager (src) txId - Description of Parameter
JMSException (src) - for any error
public 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 error
public void removeFromStorage(MessageReference (src) mh)
throws JMSException (src)
CacheStore (src)
removeFromStorage in interface CacheStore (src) mh - the message reference
JMSException (src) - for any error
public 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 error
protected 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 | |||||||||