gov.nih.nci.caarray.services.util.jms
Class JMSMessageManagerDB
java.lang.Object
gov.nih.nci.caarray.services.util.db.ManagerDB
gov.nih.nci.caarray.services.util.jms.JMSMessageManagerDB
public class JMSMessageManagerDB
- extends ManagerDB
- Author:
- Joshua Phillips
Methods inherited from class gov.nih.nci.caarray.services.util.db.ManagerDB |
clearCache, close, countObjects, countObjects, deleteMtoNRelation, deleteObject, deleteObject, deleteObject, deleteObjectByQuery, exists, getIdentifiable, getObject, getObject, getObject, getObject, getObject, getObject, getObjectIterator, getObjectIterator, getObjects, getObjects, getObjects, getPersistenceBroker, getSqlInLimit, insertMtoNRelation, insertMtoNRelation, insertObject, insertObject, link, link, removeFromCache, retrieveReference, retrieveReferences, setCascadeDelete, setCascadeRetrieve, setCascadeStore, storeObject, storeObject, unlink, unlink, updateObject, updateObject |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMSMessageManagerDB
public JMSMessageManagerDB()
- Default Constructor
JMSMessageManagerDB
public JMSMessageManagerDB(java.lang.String profileName)
- Parameters:
profileName
-
init
protected void init()
storeMessage
public org.apache.ojb.broker.Identity storeMessage(MessageData md)
throws java.lang.Exception
- Throws:
java.lang.Exception
getMessages
public MessageData[] getMessages(java.lang.String queueName)
throws java.lang.Exception
- Throws:
java.lang.Exception
deleteMessages
public boolean deleteMessages(java.lang.String queueName,
MessageData[] messages)
throws java.lang.Exception
- Throws:
java.lang.Exception
deleteByQuery
protected void deleteByQuery(org.apache.ojb.broker.query.Query query)
throws java.lang.Exception
- Description copied from class:
ManagerDB
- Delegates to OJB's deleteByQuery which executes a DELETE query.
- Overrides:
deleteByQuery
in class ManagerDB
- Throws:
DBException
java.lang.Exception
countMessages
public long countMessages(java.lang.String queueName)
throws java.lang.Exception
- Throws:
java.lang.Exception
main
public static void main(java.lang.String[] args)