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 java.lang.Object
implements MessageQueueDAO

Constructor Summary

MessageQueueDAOJpaImpl()

Method Summary

java.util.List<PersistedMessage>	findAll()
java.util.List<PersistedMessage>	findAll(int maxRows)
PersistedMessagePayload	findByPersistedMessageByRouteQueueId(java.lang.Long routeQueueId)
PersistedMessage	findByRouteQueueId(java.lang.Long routeQueueId)
java.util.List<PersistedMessage>	findByServiceName(javax.xml.namespace.QName serviceName, java.lang.String methodName)
java.util.List<PersistedMessage>	findByValues(java.util.Map<java.lang.String,java.lang.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()
java.util.List<PersistedMessage>	getNextDocuments(java.lang.Integer maxDocuments)
void	remove(PersistedMessage routeQueue)
void	save(PersistedMessage 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 java.util.List<PersistedMessage> findAll()

Specified by:

findAll in interface MessageQueueDAO

findAll

public java.util.List<PersistedMessage> findAll(int maxRows)

Specified by:

findAll in interface MessageQueueDAO

findByPersistedMessageByRouteQueueId

public PersistedMessagePayload findByPersistedMessageByRouteQueueId(java.lang.Long routeQueueId)

Specified by:

findByPersistedMessageByRouteQueueId in interface MessageQueueDAO

findByRouteQueueId

public PersistedMessage findByRouteQueueId(java.lang.Long routeQueueId)

Specified by:

findByRouteQueueId in interface MessageQueueDAO

findByServiceName

public java.util.List<PersistedMessage> findByServiceName(javax.xml.namespace.QName serviceName,
                                                          java.lang.String methodName)

Specified by:

findByServiceName in interface MessageQueueDAO

findByValues

public java.util.List<PersistedMessage> findByValues(java.util.Map<java.lang.String,java.lang.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 java.util.List<PersistedMessage> getNextDocuments(java.lang.Integer maxDocuments)

Specified by:

getNextDocuments in interface MessageQueueDAO

remove

public void remove(PersistedMessage routeQueue)

Specified by:

remove in interface MessageQueueDAO

save

public void save(PersistedMessage routeQueue)

Specified by:

save in interface MessageQueueDAO

getEntityManager

public javax.persistence.EntityManager getEntityManager()

setEntityManager

public void setEntityManager(javax.persistence.EntityManager entityManager)