gov.nih.nci.caarray.services.util.jms
Class JMSMessageManagerDB

java.lang.Object
  extended by gov.nih.nci.caarray.services.util.db.ManagerDB
      extended by gov.nih.nci.caarray.services.util.jms.JMSMessageManagerDB

public class JMSMessageManagerDB
extends ManagerDB

Author:
Joshua Phillips

Field Summary
 
Fields inherited from class gov.nih.nci.caarray.services.util.db.ManagerDB
CASCADE_LINK, CASCADE_NONE, CASCADE_OBJECT, ID_UNSET
 
Constructor Summary
JMSMessageManagerDB()
          Default Constructor
JMSMessageManagerDB(java.lang.String profileName)
           
 
Method Summary
 long countMessages(java.lang.String queueName)
           
protected  void deleteByQuery(org.apache.ojb.broker.query.Query query)
          Delegates to OJB's deleteByQuery which executes a DELETE query.
 boolean deleteMessages(java.lang.String queueName, MessageData[] messages)
           
 MessageData[] getMessages(java.lang.String queueName)
           
protected  void init()
           
static void main(java.lang.String[] args)
           
 org.apache.ojb.broker.Identity storeMessage(MessageData md)
           
 
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
 

Constructor Detail

JMSMessageManagerDB

public JMSMessageManagerDB()
Default Constructor


JMSMessageManagerDB

public JMSMessageManagerDB(java.lang.String profileName)
Parameters:
profileName -
Method Detail

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)