ome.services.blitz.impl

Class ProcessorCallbackI

java.lang.Object

ome.services.blitz.impl.AbstractAmdServant

ome.services.blitz.impl.ProcessorCallbackI

All Implemented Interfaces:

omero.grid._ProcessorCallbackOperations, org.springframework.context.ApplicationContextAware

public class ProcessorCallbackI
extends AbstractAmdServant
implements omero.grid._ProcessorCallbackOperations

Callback used to lookup active processors via IceStorm.

Field Summary

Fields inherited from class ome.services.blitz.impl.AbstractAmdServant

be, ctx, invoker, service

Constructor Summary

Constructors

Constructor and Description
ProcessorCallbackI(ServiceFactoryI sf) Simplified constructor used to see if any usermode processor is active for either the current group or the current user.
ProcessorCallbackI(ServiceFactoryI sf, ResultHolder<omero.grid.ProcessorPrx> holder, omero.model.Job job) Primary constructor.

Method Summary

Methods

Modifier and Type	Method and Description
omero.grid.ProcessorPrx	activateAndWait(Ice.Current current) Generates a UUID-based Identity with the category of PROCESSORCALLBACK.value and then calls {@link #activateAndWait(Current, Ice.Identity).
omero.grid.ProcessorPrx	activateAndWait(Ice.Current current, Ice.Identity acceptId) Primary method which adds this instance to IceStorm, waits for a response from any active processor services, and finally unregister itself before returning the first processor instance which responded.
int	getResponses() Return the number of times this instance has been called in a thread safe manner.
void	isAccepted(boolean accepted, String sessionUuid, String procConn, Ice.Current __current) Deprecated.
void	isProxyAccepted(boolean accepted, String sessionUuid, omero.grid.ProcessorPrx procProxy, Ice.Current __current) Callback method called by the remote processor instance.
void	responseRunning(List<Long> jobIds, Ice.Current __current) Callback method which should not be called for this instance.

Methods inherited from class ome.services.blitz.impl.AbstractAmdServant

activate_async, applyHardWiredInterceptors, callInvokerOnMappedArgs, callInvokerOnRawArgs, executorWorkCall, getCurrentEventContext_async, onSetOmeroContext, passivate_async, runnableCall, safeRunnableCall, setApplicationContext, setHolder

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessorCallbackI

public ProcessorCallbackI(ServiceFactoryI sf)

Simplified constructor used to see if any usermode processor is active for either the current group or the current user. Currently uses a hard-coded value of 5 seconds wait time. For more control, pass in a ResultHolder instance.

ProcessorCallbackI

public ProcessorCallbackI(ServiceFactoryI sf,
                  ResultHolder<omero.grid.ProcessorPrx> holder,
                  omero.model.Job job)

Primary constructor. Asks processors if they will accept the given job for the current user and the current group.

Parameters:

sf - Cannot be null.

holder - Cannot be null.

job - Can be null.

Method Detail

getResponses

public int getResponses()

Return the number of times this instance has been called in a thread safe manner.

activateAndWait

public omero.grid.ProcessorPrx activateAndWait(Ice.Current current)
                                        throws omero.ServerError

Generates a UUID-based Identity with the category of PROCESSORCALLBACK.value and then calls {@link #activateAndWait(Current, Ice.Identity).

Throws:

omero.ServerError

activateAndWait

public omero.grid.ProcessorPrx activateAndWait(Ice.Current current,
                                      Ice.Identity acceptId)
                                        throws omero.ServerError

Primary method which adds this instance to IceStorm, waits for a response from any active processor services, and finally unregister itself before returning the first processor instance which responded.

Parameters:

current -

acceptId -

Returns:

Throws:

omero.ServerError

isAccepted

@Deprecated
public void isAccepted(boolean accepted,
                         String sessionUuid,
                         String procConn,
                         Ice.Current __current)

Deprecated.

Callback method called by the remote processor instance. See ticket 8266 for reasons this method should not be used.

Specified by:

isAccepted in interface omero.grid._ProcessorCallbackOperations

isProxyAccepted

public void isProxyAccepted(boolean accepted,
                   String sessionUuid,
                   omero.grid.ProcessorPrx procProxy,
                   Ice.Current __current)

Callback method called by the remote processor instance.

Specified by:

isProxyAccepted in interface omero.grid._ProcessorCallbackOperations

responseRunning

public void responseRunning(List<Long> jobIds,
                   Ice.Current __current)

Callback method which should not be called for this instance.

Specified by:

responseRunning in interface omero.grid._ProcessorCallbackOperations