| java.lang.Object
 edu.iu.uis.eden.messaging.MessageServiceInvoker
| MessageServiceInvoker | | public class MessageServiceInvoker implements Runnable(Code) | | Handles invocation of a
PersistedMessage .
author:
Kuali Rice Team (kuali-rice@googlegroups.com) |
| Field Summary | |
| final protected static Logger | LOG
|
| LOG | | final protected static Logger LOG(Code) | | |
| getQueueService | | public Object getQueueService(ServiceInfo serviceInfo)(Code) | | Because this is a queue we just need to grab one.
Parameters:
serviceInfo - |
| getTopicService | | public Object getTopicService(ServiceInfo serviceInfo)(Code) | | Get the service as a topic. This means we want to contact every service that is a part of this topic. We've
grabbed all the services that are a part of this topic and we want to make sure that we get everyone of them =
that is we want to circumvent loadbalancing and therefore not ask for the service by it's name but the url to get
the exact service we want.
Parameters:
serviceInfo - |
| invokeService | | public Object invokeService(AsynchronousCall methodCall) throws Exception(Code) | | Invokes the AsynchronousCall represented on the methodCall on the service contained in the ServiceInfo object on
the AsynchronousCall.
|
| notifyOnCallback | | public void notifyOnCallback(AsynchronousCall methodCall, Object callResult)(Code) | | Used in case the thread that dumped this work into the queue is waiting for the work to be done to continue
processing.
Parameters:
callback - |
|
|