org.kuali.rice.ksb.messaging.service.impl
Class MessageQueueServiceImpl

java.lang.Object
  org.kuali.rice.ksb.messaging.service.impl.MessageQueueServiceImpl

All Implemented Interfaces:

MessageQueueService

public class MessageQueueServiceImpl
extends Object
implements MessageQueueService

Constructor Summary

MessageQueueServiceImpl()

Method Summary

void	delete(PersistedMessageBO routeQueue)
List<PersistedMessageBO>	findAll()
List<PersistedMessageBO>	findAll(int maxRows)
PersistedMessagePayload	findByPersistedMessageByRouteQueueId(Long routeQueueId)
PersistedMessageBO	findByRouteQueueId(Long routeQueueId) Finds the PersistedMessageBO identified by the passed-in primary key, if one is available, otherwise returns a null object.
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 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.
PersistedMessageBO	getMessage(ServiceInfo serviceInfo, AsynchronousCall methodCall)
MessageQueueDAO	getMessageQueueDAO()
List<PersistedMessageBO>	getNextDocuments(Integer maxDocuments) Returns a List of RouteQueue documents which are queued for routing.
void	save(PersistedMessageBO routeQueue)
void	setMessageQueueDAO(MessageQueueDAO queueDAO)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageQueueServiceImpl

public MessageQueueServiceImpl()

Method Detail

delete

public void delete(PersistedMessageBO routeQueue)

Specified by:

delete in interface MessageQueueService

save

public void save(PersistedMessageBO routeQueue)

Specified by:

save in interface MessageQueueService

findAll

public List<PersistedMessageBO> findAll()

Specified by:

findAll in interface MessageQueueService

findAll

public List<PersistedMessageBO> findAll(int maxRows)

Specified by:

findAll in interface MessageQueueService

findByRouteQueueId

public PersistedMessageBO findByRouteQueueId(Long routeQueueId)

Description copied from interface: MessageQueueService

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

Specified by:

findByRouteQueueId in interface MessageQueueService

Parameters:

routeQueueId - The primary key routeQueueId of the message desired.

Returns:

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

findByPersistedMessageByRouteQueueId

public PersistedMessagePayload findByPersistedMessageByRouteQueueId(Long routeQueueId)

Specified by:

findByPersistedMessageByRouteQueueId in interface MessageQueueService

getNextDocuments

public List<PersistedMessageBO> getNextDocuments(Integer maxDocuments)

Description copied from interface: MessageQueueService

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

Specified by:

getNextDocuments in interface MessageQueueService

getMessageQueueDAO

public MessageQueueDAO getMessageQueueDAO()

setMessageQueueDAO

public void setMessageQueueDAO(MessageQueueDAO queueDAO)

findByServiceName

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

Specified by:

findByServiceName in interface MessageQueueService

findByValues

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

Description copied from interface: MessageQueueService

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

Specified by:

findByValues in interface MessageQueueService

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

public Integer getMaxRetryAttempts()

Description copied from interface: MessageQueueService

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

Specified by:

getMaxRetryAttempts in interface MessageQueueService

Returns:

The max retry attempts set in the system.

getMessage

public PersistedMessageBO getMessage(ServiceInfo serviceInfo,
                                     AsynchronousCall methodCall)

Specified by:

getMessage in interface MessageQueueService