Modifier and Type | Method and Description |
---|---|
DocumentRouteHeaderValue |
WorkflowDocumentExceptionRoutingService.placeInExceptionRouting(String errorMessage,
PersistedMessageBO persistedMessage,
String documentId) |
DocumentRouteHeaderValue |
WorkflowDocumentExceptionRoutingService.placeInExceptionRouting(Throwable throwable,
PersistedMessageBO persistedMessage,
String documentId) |
void |
WorkflowDocumentExceptionRoutingService.placeInExceptionRoutingLastDitchEffort(Throwable throwable,
PersistedMessageBO persistedMessage,
String documentId) |
Modifier and Type | Method and Description |
---|---|
protected String |
DocumentMessageExceptionHandler.getDocumentId(PersistedMessageBO message) |
void |
DocumentMessageExceptionHandler.handleExceptionLastDitchEffort(Throwable throwable,
PersistedMessageBO message,
Object service) |
protected void |
DocumentMessageExceptionHandler.placeInException(Throwable throwable,
PersistedMessageBO message) |
DocumentRouteHeaderValue |
ExceptionRoutingServiceImpl.placeInExceptionRouting(String errorMessage,
PersistedMessageBO persistedMessage,
String documentId) |
protected DocumentRouteHeaderValue |
ExceptionRoutingServiceImpl.placeInExceptionRouting(String errorMessage,
RouteNodeInstance nodeInstance,
PersistedMessageBO persistedMessage,
RouteContext routeContext,
DocumentRouteHeaderValue document,
boolean invokePostProcessor) |
DocumentRouteHeaderValue |
ExceptionRoutingServiceImpl.placeInExceptionRouting(Throwable throwable,
PersistedMessageBO persistedMessage,
String documentId) |
protected DocumentRouteHeaderValue |
ExceptionRoutingServiceImpl.placeInExceptionRouting(Throwable throwable,
PersistedMessageBO persistedMessage,
String documentId,
boolean invokePostProcessor) |
void |
ExceptionRoutingServiceImpl.placeInExceptionRoutingLastDitchEffort(Throwable throwable,
PersistedMessageBO persistedMessage,
String documentId)
In our case here, our last ditch effort to put the document into exception routing will try to do so without invoking
the Post Processor for do route status change to "Exception" status.
|
protected void |
DocumentMessageExceptionHandler.scheduleExecution(Throwable throwable,
PersistedMessageBO message) |
Modifier and Type | Method and Description |
---|---|
static PersistedMessageBO |
PersistedMessageBO.buildMessage(ServiceConfiguration serviceConfiguration,
AsynchronousCall methodCall) |
PersistedMessageBO |
PersistedMessageBO.copy() |
PersistedMessageBO |
PersistedMessagePayload.getMessage() |
PersistedMessageBO |
MessageServiceInvoker.getMessage() |
Modifier and Type | Method and Description |
---|---|
void |
PersistedMessagePayload.setMessage(PersistedMessageBO message) |
void |
MessageServiceInvoker.setMessage(PersistedMessageBO message) |
Constructor and Description |
---|
MessageServiceInvoker(PersistedMessageBO message) |
PersistedMessagePayload(AsynchronousCall methodCall,
PersistedMessageBO message) |
Modifier and Type | Method and Description |
---|---|
PersistedMessageBO |
MessageQueueDAO.findByRouteQueueId(Long routeQueueId) |
PersistedMessageBO |
MessageQueueDAO.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
List<PersistedMessageBO> |
MessageQueueDAO.findAll() |
List<PersistedMessageBO> |
MessageQueueDAO.findAll(int maxRows) |
List<PersistedMessageBO> |
MessageQueueDAO.findByServiceName(QName serviceName,
String methodName) |
List<PersistedMessageBO> |
MessageQueueDAO.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> |
MessageQueueDAO.getNextDocuments(Integer maxDocuments) |
Modifier and Type | Method and Description |
---|---|
void |
MessageQueueDAO.remove(PersistedMessageBO routeQueue) |
PersistedMessageBO |
MessageQueueDAO.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
PersistedMessageBO |
MessageQueueDaoJpa.findByRouteQueueId(Long routeQueueId) |
PersistedMessageBO |
MessageQueueDaoJpa.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
List<PersistedMessageBO> |
MessageQueueDaoJpa.findAll() |
List<PersistedMessageBO> |
MessageQueueDaoJpa.findAll(int maxRows) |
List<PersistedMessageBO> |
MessageQueueDaoJpa.findByServiceName(QName serviceName,
String methodName) |
List<PersistedMessageBO> |
MessageQueueDaoJpa.findByValues(Map<String,String> criteriaValues,
int maxRows) |
List<PersistedMessageBO> |
MessageQueueDaoJpa.getNextDocuments(Integer maxDocuments) |
Modifier and Type | Method and Description |
---|---|
void |
MessageQueueDaoJpa.remove(PersistedMessageBO routeQueue) |
PersistedMessageBO |
MessageQueueDaoJpa.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
void |
MessageExceptionHandler.handleException(Throwable throwable,
PersistedMessageBO message,
Object service) |
void |
DefaultMessageExceptionHandler.handleException(Throwable throwable,
PersistedMessageBO message,
Object service) |
void |
MessageExceptionHandler.handleExceptionLastDitchEffort(Throwable throwable,
PersistedMessageBO message,
Object service) |
void |
DefaultMessageExceptionHandler.handleExceptionLastDitchEffort(Throwable throwable,
PersistedMessageBO message,
Object service) |
boolean |
MessageExceptionHandler.isInException(PersistedMessageBO message)
Determines whether the message would go into Exception if submitted.
|
boolean |
DefaultMessageExceptionHandler.isInException(PersistedMessageBO message) |
protected void |
DefaultMessageExceptionHandler.placeInException(Throwable throwable,
PersistedMessageBO message) |
void |
ExceptionRoutingService.placeInExceptionRouting(Throwable throwable,
PersistedMessageBO message,
Object service) |
void |
DefaultExceptionServiceImpl.placeInExceptionRouting(Throwable throwable,
PersistedMessageBO message,
Object service) |
void |
ExceptionRoutingService.placeInExceptionRoutingLastDitchEffort(Throwable throwable,
PersistedMessageBO message,
Object service) |
void |
DefaultExceptionServiceImpl.placeInExceptionRoutingLastDitchEffort(Throwable throwable,
PersistedMessageBO message,
Object service) |
protected void |
DefaultMessageExceptionHandler.requeue(Throwable throwable,
PersistedMessageBO message) |
protected void |
DefaultMessageExceptionHandler.scheduleExecution(Throwable throwable,
PersistedMessageBO message) |
void |
ExceptionRoutingService.scheduleExecution(Throwable throwable,
PersistedMessageBO message,
String description) |
void |
DefaultExceptionServiceImpl.scheduleExecution(Throwable throwable,
PersistedMessageBO message,
String description) |
Modifier and Type | Method and Description |
---|---|
PersistedMessageBO |
MessageQueueService.findByRouteQueueId(Long routeQueueId)
Finds the PersistedMessageBO identified by the passed-in primary key, if one is
available, otherwise returns a null object.
|
PersistedMessageBO |
MessageQueueService.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
List<PersistedMessageBO> |
MessageQueueService.findAll() |
List<PersistedMessageBO> |
MessageQueueService.findAll(int maxRows) |
List<PersistedMessageBO> |
MessageQueueService.findByServiceName(QName serviceName,
String methodName) |
List<PersistedMessageBO> |
MessageQueueService.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.
|
List<PersistedMessageBO> |
MessageQueueService.getNextDocuments(Integer maxDocuments)
Returns a List of RouteQueue documents which are queued for routing.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageQueueService.delete(PersistedMessageBO routeQueue) |
PersistedMessageBO |
MessageQueueService.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
PersistedMessageBO |
MessageQueueServiceImpl.findByRouteQueueId(Long routeQueueId) |
PersistedMessageBO |
MessageQueueServiceImpl.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
List<PersistedMessageBO> |
MessageQueueServiceImpl.findAll() |
List<PersistedMessageBO> |
MessageQueueServiceImpl.findAll(int maxRows) |
List<PersistedMessageBO> |
MessageQueueServiceImpl.findByServiceName(QName serviceName,
String methodName) |
List<PersistedMessageBO> |
MessageQueueServiceImpl.findByValues(Map<String,String> criteriaValues,
int maxRows) |
List<PersistedMessageBO> |
MessageQueueServiceImpl.getNextDocuments(Integer maxDocuments) |
Modifier and Type | Method and Description |
---|---|
void |
MessageQueueServiceImpl.delete(PersistedMessageBO routeQueue) |
PersistedMessageBO |
MessageQueueServiceImpl.save(PersistedMessageBO routeQueue) |
Modifier and Type | Method and Description |
---|---|
protected PersistedMessageBO |
AsynchronousServiceCallProxy.saveMessage(PersistedMessageBO message) |
Modifier and Type | Method and Description |
---|---|
protected void |
SynchronousServiceCallProxy.executeMessage(PersistedMessageBO message) |
protected void |
AsynchronousServiceCallProxy.executeMessage(PersistedMessageBO message) |
protected PersistedMessageBO |
AsynchronousServiceCallProxy.saveMessage(PersistedMessageBO message) |
protected void |
DelayedAsynchronousServiceCallProxy.scheduleMessage(PersistedMessageBO message) |
static void |
MessageSender.sendMessage(PersistedMessageBO message) |
Constructor and Description |
---|
MessageSendingTransactionSynchronization(PersistedMessageBO message) |
Modifier and Type | Method and Description |
---|---|
PersistedMessageBO |
MessageQueueForm.getMessageQueueFromDatabase() |
PersistedMessageBO |
MessageQueueForm.getMessageQueueFromForm() |
protected PersistedMessageBO |
MessageQueueAction.quickRequeueMessage(PersistedMessageBO message)
Performs a quick ReQueue of the indicated persisted message.
|
Modifier and Type | Method and Description |
---|---|
protected List<PersistedMessageBO> |
MessageQueueAction.findRouteQueues(javax.servlet.http.HttpServletRequest request,
MessageQueueForm routeQueueForm,
int maxRows) |
Collection<PersistedMessageBO> |
MessageQueueForm.getMessageQueueRows() |
Modifier and Type | Method and Description |
---|---|
protected PersistedMessageBO |
MessageQueueAction.quickRequeueMessage(PersistedMessageBO message)
Performs a quick ReQueue of the indicated persisted message.
|
void |
MessageQueueForm.setMessageQueueFromDatabase(PersistedMessageBO existingRouteQueue) |
void |
MessageQueueForm.setMessageQueueFromForm(PersistedMessageBO routeQueue) |
protected AsynchronousCall |
MessageQueueAction.unwrapPayload(PersistedMessageBO message)
Extracts the payload from a PersistedMessageBO, attempts to convert it to the expected AsynchronousCall type, and
returns it.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageQueueForm.setMessageQueueRows(Collection<PersistedMessageBO> routeQueueRows) |
Copyright © 2005–2015 The Kuali Foundation. All rights reserved.