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

java.lang.Object
  org.kuali.rice.ksb.messaging.dao.impl.MessageQueueDAOJpaImpl

All Implemented Interfaces:

MessageQueueDAO

public class MessageQueueDAOJpaImpl
extends Object
implements MessageQueueDAO

Constructor Summary

MessageQueueDAOJpaImpl()

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.
javax.persistence.EntityManager	getEntityManager()
List<PersistedMessageBO>	getNextDocuments(Integer maxDocuments)
void	remove(PersistedMessageBO routeQueue)
void	save(PersistedMessageBO routeQueue)
void	setEntityManager(javax.persistence.EntityManager entityManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageQueueDAOJpaImpl

public MessageQueueDAOJpaImpl()

Method Detail

findAll

public List<PersistedMessageBO> findAll()

Specified by:

findAll in interface MessageQueueDAO

findAll

public List<PersistedMessageBO> findAll(int maxRows)

Specified by:

findAll in interface MessageQueueDAO

findByPersistedMessageByRouteQueueId

public PersistedMessagePayload findByPersistedMessageByRouteQueueId(Long routeQueueId)

Specified by:

findByPersistedMessageByRouteQueueId in interface MessageQueueDAO

findByRouteQueueId

public PersistedMessageBO findByRouteQueueId(Long routeQueueId)

Specified by:

findByRouteQueueId in interface MessageQueueDAO

findByServiceName

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

Specified by:

findByServiceName 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.

getNextDocuments

public List<PersistedMessageBO> getNextDocuments(Integer maxDocuments)

Specified by:

getNextDocuments in interface MessageQueueDAO

remove

public void remove(PersistedMessageBO routeQueue)

Specified by:

remove in interface MessageQueueDAO

save

public void save(PersistedMessageBO routeQueue)

Specified by:

save in interface MessageQueueDAO

getEntityManager

public javax.persistence.EntityManager getEntityManager()

setEntityManager

public void setEntityManager(javax.persistence.EntityManager entityManager)