org.kuali.rice.ksb.messaging.serviceproxies

Class DelayedAsynchronousServiceCallProxy

java.lang.Object

org.kuali.rice.core.api.util.reflect.BaseInvocationHandler

org.kuali.rice.ksb.messaging.serviceproxies.DelayedAsynchronousServiceCallProxy

All Implemented Interfaces:

InvocationHandler, TargetedInvocationHandler

public class DelayedAsynchronousServiceCallProxy
extends BaseInvocationHandler
implements TargetedInvocationHandler

A proxy which schedules a service to be executed asynchronously after some delay period.

Author:

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DelayedAsynchronousServiceCallProxy(List<Endpoint> endpoints, Serializable context, String value1, String value2, long delayMilliseconds)

Method Summary

Modifier and Type	Method and Description
static Object	createInstance(List<Endpoint> endpoints, Serializable context, String value1, String value2, long delayMilliseconds)
Object	getTarget() Returns the List of asynchronous services which will be invoked by calls to this proxy.
protected Object	invokeInternal(Object proxy, Method method, Object[] arguments)
protected void	scheduleMessage(PersistedMessageBO message)

Methods inherited from class org.kuali.rice.core.api.util.reflect.BaseInvocationHandler

invoke, proxyEquals, proxyHashCode, proxyToString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.reflect.InvocationHandler

invoke

Constructor Detail

DelayedAsynchronousServiceCallProxy

protected DelayedAsynchronousServiceCallProxy(List<Endpoint> endpoints,
                                              Serializable context,
                                              String value1,
                                              String value2,
                                              long delayMilliseconds)

Method Detail

createInstance

public static Object createInstance(List<Endpoint> endpoints,
                                    Serializable context,
                                    String value1,
                                    String value2,
                                    long delayMilliseconds)

invokeInternal

protected Object invokeInternal(Object proxy,
                                Method method,
                                Object[] arguments)
                         throws Throwable

Specified by:

invokeInternal in class BaseInvocationHandler

Throws:

Throwable

scheduleMessage

protected void scheduleMessage(PersistedMessageBO message)
                        throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

getTarget

public Object getTarget()

Returns the List of asynchronous services which will be invoked by calls to this proxy. This is a List because, in the case of Topics, there can be more than one service invoked.

Specified by:

getTarget in interface TargetedInvocationHandler

Returns:

the target object