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

protected

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

Method Summary

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

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