org.kuali.rice.ksb.messaging.service
Interface MessageQueueService

All Known Implementing Classes:

MessageQueueServiceImpl

public interface MessageQueueService

Service for interfacing with the queue of asynchronous messages.

Author:

Kuali Rice Team (rice.collab@kuali.org)

See Also:

PersistedMessage

Method Summary

void	delete(PersistedMessage routeQueue)
List<PersistedMessage>	findAll()
List<PersistedMessage>	findAll(int maxRows)
PersistedMessagePayload	findByPersistedMessageByRouteQueueId(Long routeQueueId)
PersistedMessage	findByRouteQueueId(Long routeQueueId) Finds the PersistedMessage identified by the passed-in primary key, if one is available, otherwise returns a null object.
List<PersistedMessage>	findByServiceName(QName serviceName, String methodName)
List<PersistedMessage>	findByValues(Map<String,String> criteriaValues, int maxRows) Finds the persisted messages that match the values passed into the criteriaValues Map, with an auto-wildcard function, if no wildcard is passed in.
Integer	getMaxRetryAttempts() Used to determine the maximum number of retries allowed by the system before the message goes into Exception.
PersistedMessage	getMessage(ServiceInfo serviceInfo, AsynchronousCall methodCall)
List<PersistedMessage>	getNextDocuments(Integer maxDocuments) Returns a List of RouteQueue documents which are queued for routing.
void	save(PersistedMessage routeQueue)

Method Detail

findByServiceName

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

delete

void delete(PersistedMessage routeQueue)

save

void save(PersistedMessage routeQueue)

findAll

List<PersistedMessage> findAll()

findAll

List<PersistedMessage> findAll(int maxRows)

findByRouteQueueId

PersistedMessage findByRouteQueueId(Long routeQueueId)

Finds the PersistedMessage identified by the passed-in primary key, if one is available, otherwise returns a null object.

Parameters:

routeQueueId - The primary key routeQueueId of the message desired.

Returns:

A populated PersistedMessage instance, if the routeQueueId exists, otherwise a null object.

getNextDocuments

List<PersistedMessage> getNextDocuments(Integer maxDocuments)

Returns a List of RouteQueue documents which are queued for routing. Will not return more RouteQueues than the value of maxDocuments.

findByPersistedMessageByRouteQueueId

PersistedMessagePayload findByPersistedMessageByRouteQueueId(Long routeQueueId)

findByValues

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

Finds the persisted messages that match the values passed into the criteriaValues Map, with an auto-wildcard function, if no wildcard is passed in.

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.

maxRows - the maximum number of rows to return from the query. If -1, then all rows will be returned.

Returns:

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

getMaxRetryAttempts

Integer getMaxRetryAttempts()

Used to determine the maximum number of retries allowed by the system before the message goes into Exception.

Returns:

The max retry attempts set in the system.

getMessage

PersistedMessage getMessage(ServiceInfo serviceInfo,
                            AsynchronousCall methodCall)