org.kuali.rice.ksb.messaging.dao

Interface MessageQueueDAO

All Known Implementing Classes:

MessageQueueDAOJpaImpl, MessageQueueDAOOjbImpl

public interface MessageQueueDAO

Method Summary

Modifier and Type	Method and Description
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)

Method Detail

remove

void remove(PersistedMessageBO routeQueue)

save

void save(PersistedMessageBO routeQueue)

findByRouteQueueId

PersistedMessageBO findByRouteQueueId(Long routeQueueId)

findAll

List<PersistedMessageBO> findAll()

findAll

List<PersistedMessageBO> findAll(int maxRows)

getNextDocuments

List<PersistedMessageBO> getNextDocuments(Integer maxDocuments)

findByServiceName

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

findByValues

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.

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.

findByPersistedMessageByRouteQueueId

PersistedMessagePayload findByPersistedMessageByRouteQueueId(Long routeQueueId)