ome.services.throttling

Class InThreadThrottlingStrategy

java.lang.Object

ome.services.throttling.AbstractThrottlingStrategy

ome.services.throttling.InThreadThrottlingStrategy

All Implemented Interfaces:

EventListener, BlitzExecutor, ThrottlingStrategy, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener

public class InThreadThrottlingStrategy
extends AbstractThrottlingStrategy

Throttling implementation which uses the calling server Thread for execution. This mimics the behavior of the pre-AMD blitz.

Field Summary

Fields inherited from class ome.services.throttling.AbstractThrottlingStrategy

ctx

Constructor Summary

Constructors

Constructor and Description
InThreadThrottlingStrategy(CurrentDetails cd)

Method Summary

Modifier and Type	Method and Description
void	callInvokerOnRawArgs(ServiceInterface service, IceMethodInvoker invoker, Object __cb, Ice.Current __current, Object... args) Uses the given IceMethodInvoker to make the method call.
void	callInvokerWithMappedArgs(ServiceInterface service, IceMethodInvoker invoker, IceMapper mapper, Object __cb, Ice.Current __current, Object... args) Passes the given arguments to IceMethodInvoker with the assumption that all conversion from omero.* to ome.* has taken place.
void	runnableCall(Ice.Current __current, Task runnable)
<R> void	safeRunnableCall(Ice.Current __current, Object __cb, boolean isVoid, Callable<R> callable)

Methods inherited from class ome.services.throttling.AbstractThrottlingStrategy

onApplicationEvent, setApplicationContext

Methods inherited from class java.lang.Object

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

Constructor Detail

InThreadThrottlingStrategy

public InThreadThrottlingStrategy(CurrentDetails cd)

Method Detail

callInvokerOnRawArgs

public void callInvokerOnRawArgs(ServiceInterface service,
                                 IceMethodInvoker invoker,
                                 Object __cb,
                                 Ice.Current __current,
                                 Object... args)

Description copied from interface: BlitzExecutor

Uses the given IceMethodInvoker to make the method call. All arguments are passed directly into the invoker, and the return value from the invoker is passed to the user.

callInvokerWithMappedArgs

public void callInvokerWithMappedArgs(ServiceInterface service,
                                      IceMethodInvoker invoker,
                                      IceMapper mapper,
                                      Object __cb,
                                      Ice.Current __current,
                                      Object... args)

Description copied from interface: BlitzExecutor

Passes the given arguments to IceMethodInvoker with the assumption that all conversion from omero.* to ome.* has taken place. Similarly, the IceMapper instance will be used to map the return value from ome.* to omero.*.

safeRunnableCall

public <R> void safeRunnableCall(Ice.Current __current,
                                 Object __cb,
                                 boolean isVoid,
                                 Callable<R> callable)

runnableCall

public void runnableCall(Ice.Current __current,
                         Task runnable)