org.kuali.rice.ksb.messaging.dao.impl
Class MessageQueueDAOOjbImpl

java.lang.Object
  org.springframework.dao.support.DaoSupport
      org.springmodules.orm.ojb.support.PersistenceBrokerDaoSupport
          org.kuali.rice.ksb.messaging.dao.impl.MessageQueueDAOOjbImpl

All Implemented Interfaces:

MessageQueueDAO, org.springframework.beans.factory.InitializingBean

public class MessageQueueDAOOjbImpl
extends org.springmodules.orm.ojb.support.PersistenceBrokerDaoSupport
implements MessageQueueDAO

Field Summary

Fields inherited from class org.springframework.dao.support.DaoSupport

logger

Constructor Summary

MessageQueueDAOOjbImpl()

Method Summary

List<PersistedMessageBO>	findAll()
List<PersistedMessageBO>	findAll(int maxRows)
PersistedMessagePayload	findByPersistedMessageByRouteQueueId(Long routeQueueId)
PersistedMessageBO	findByRouteQueueId(Long routeQueueId)
List<PersistedMessageBO>	findByServiceName(QName serviceName, String methodName)
List<PersistedMessageBO>	findByValues(Map<String,String> criteriaValues, int maxRows) Finds the persisted messages that match the values passed into the criteriaValues Map, with an EqualTo criteria for each.
List<PersistedMessageBO>	getNextDocuments(Integer maxDocuments)
void	remove(PersistedMessageBO routeQueue)
void	save(PersistedMessageBO routeQueue)

Methods inherited from class org.springmodules.orm.ojb.support.PersistenceBrokerDaoSupport

checkDaoConfig, convertOjbAccessException, createPersistenceBrokerTemplate, getJcdAlias, getPersistenceBroker, getPersistenceBrokerTemplate, releasePersistenceBroker, setJcdAlias, setPersistenceBrokerTemplate

Methods inherited from class org.springframework.dao.support.DaoSupport

afterPropertiesSet, initDao

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessageQueueDAOOjbImpl

public MessageQueueDAOOjbImpl()

Method Detail

remove

public void remove(PersistedMessageBO routeQueue)

Specified by:

remove in interface MessageQueueDAO

save

public void save(PersistedMessageBO routeQueue)

Specified by:

save in interface MessageQueueDAO

findAll

public List<PersistedMessageBO> findAll()

Specified by:

findAll in interface MessageQueueDAO

findAll

public List<PersistedMessageBO> findAll(int maxRows)

Specified by:

findAll in interface MessageQueueDAO

findByValues

public List<PersistedMessageBO> findByValues(Map<String,String> criteriaValues,
                                             int maxRows)

Description copied from interface: MessageQueueDAO

Finds the persisted messages that match the values passed into the criteriaValues Map, with an EqualTo criteria for each.

Specified by:

findByValues in interface MessageQueueDAO

Parameters:

criteriaValues - A Map of Key/Value pairs, where the Key is a string holding the field name, and the Value is a string holding the value to match.

Returns:

A populated (or empty) list containing the results of the search. If no matches are made, an empty list will be returned.

findByRouteQueueId

public PersistedMessageBO findByRouteQueueId(Long routeQueueId)

Specified by:

findByRouteQueueId in interface MessageQueueDAO

findByPersistedMessageByRouteQueueId

public PersistedMessagePayload findByPersistedMessageByRouteQueueId(Long routeQueueId)

Specified by:

findByPersistedMessageByRouteQueueId in interface MessageQueueDAO

getNextDocuments

public List<PersistedMessageBO> getNextDocuments(Integer maxDocuments)

Specified by:

getNextDocuments in interface MessageQueueDAO

findByServiceName

public List<PersistedMessageBO> findByServiceName(QName serviceName,
                                                  String methodName)

Specified by:

findByServiceName in interface MessageQueueDAO