public class ProcessorCallbackI extends AbstractAmdServant implements omero.grid._ProcessorCallbackOperations
be, ctx, invoker, service
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.
|
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
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.
|
activate_async, applyHardWiredInterceptors, callInvokerOnMappedArgs, callInvokerOnRawArgs, executorWorkCall, getCurrentEventContext_async, onSetOmeroContext, passivate_async, runnableCall, safeRunnableCall, setApplicationContext, setHolder
public ProcessorCallbackI(ServiceFactoryI sf)
ResultHolder
instance.public ProcessorCallbackI(ServiceFactoryI sf, ResultHolder<omero.grid.ProcessorPrx> holder, omero.model.Job job)
sf
- Cannot be null.holder
- Cannot be null.job
- Can be null.public int getResponses()
public omero.grid.ProcessorPrx activateAndWait(Ice.Current current) throws omero.ServerError
Identity
with the category of
PROCESSORCALLBACK.value
and then calls
activateAndWait(Current, Ice.Identity)
.omero.ServerError
public omero.grid.ProcessorPrx activateAndWait(Ice.Current current, Ice.Identity acceptId) throws omero.ServerError
current
- acceptId
- omero.ServerError
@Deprecated public void isAccepted(boolean accepted, String sessionUuid, String procConn, Ice.Current __current)
isAccepted
in interface omero.grid._ProcessorCallbackOperations
public void isProxyAccepted(boolean accepted, String sessionUuid, omero.grid.ProcessorPrx procProxy, Ice.Current __current)
isProxyAccepted
in interface omero.grid._ProcessorCallbackOperations
Version: 5.3.5-ice35-b73
Copyright © 2017 The University of Dundee & Open Microscopy Environment. All Rights Reserved.