Package omero.grid
Interface ProcessorPrx
-
- All Superinterfaces:
Ice.ObjectPrx
- All Known Implementing Classes:
ProcessorPrxHelper
public interface ProcessorPrx extends Ice.ObjectPrx
Simple controller for Processes. Uses the session id given to create an Ice.Config file which is used as the sole argument to an execution of the given job. Jobs are responsible for loading arguments from the environment via the session id.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, Ice.Callback __cb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_parseJob __cb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_parseJob(java.lang.String session, Job jobObject, Callback_Processor_parseJob __cb)
Parses a job and returns metadata definition required for properly submitting the job.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, Ice.Callback __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_processJob __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_processJob(java.lang.String session, JobParams params, Job jobObject, Callback_Processor_processJob __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, Ice.Callback __cb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_requestRunning __cb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_requestRunning(ProcessorCallbackPrx cb, Callback_Processor_requestRunning __cb)
Used by servers to find out what jobs are still active.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, Ice.Callback __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_willAccept __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.Ice.AsyncResult
begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, Callback_Processor_willAccept __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.JobParams
end_parseJob(Ice.AsyncResult __result)
Parses a job and returns metadata definition required for properly submitting the job.ProcessPrx
end_processJob(Ice.AsyncResult __result)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.void
end_requestRunning(Ice.AsyncResult __result)
Used by servers to find out what jobs are still active.void
end_willAccept(Ice.AsyncResult __result)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.JobParams
parseJob(java.lang.String session, Job jobObject)
Parses a job and returns metadata definition required for properly submitting the job.JobParams
parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx)
Parses a job and returns metadata definition required for properly submitting the job.ProcessPrx
processJob(java.lang.String session, JobParams params, Job jobObject)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.ProcessPrx
processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.void
requestRunning(ProcessorCallbackPrx cb)
Used by servers to find out what jobs are still active.void
requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Used by servers to find out what jobs are still active.void
willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.void
willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
.-
Methods inherited from interface Ice.ObjectPrx
begin_ice_flushBatchRequests, begin_ice_flushBatchRequests, begin_ice_flushBatchRequests, begin_ice_flushBatchRequests, begin_ice_getConnection, begin_ice_getConnection, begin_ice_getConnection, begin_ice_getConnection, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_id, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_ids, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_invoke, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_isA, begin_ice_ping, begin_ice_ping, begin_ice_ping, begin_ice_ping, begin_ice_ping, begin_ice_ping, begin_ice_ping, begin_ice_ping, begin_ice_ping, begin_ice_ping, end_ice_flushBatchRequests, end_ice_getConnection, end_ice_id, end_ice_ids, end_ice_invoke, end_ice_isA, end_ice_ping, equals, ice_adapterId, ice_batchDatagram, ice_batchOneway, ice_collocationOptimized, ice_compress, ice_connectionCached, ice_connectionId, ice_context, ice_datagram, ice_encodingVersion, ice_endpoints, ice_endpointSelection, ice_facet, ice_flushBatchRequests, ice_getAdapterId, ice_getCachedConnection, ice_getCommunicator, ice_getConnection, ice_getConnectionId, ice_getContext, ice_getEncodingVersion, ice_getEndpoints, ice_getEndpointSelection, ice_getFacet, ice_getIdentity, ice_getInvocationTimeout, ice_getLocator, ice_getLocatorCacheTimeout, ice_getRouter, ice_id, ice_id, ice_identity, ice_ids, ice_ids, ice_invocationTimeout, ice_invoke, ice_invoke, ice_isA, ice_isA, ice_isBatchDatagram, ice_isBatchOneway, ice_isCollocationOptimized, ice_isConnectionCached, ice_isDatagram, ice_isOneway, ice_isPreferSecure, ice_isSecure, ice_isTwoway, ice_locator, ice_locatorCacheTimeout, ice_oneway, ice_ping, ice_ping, ice_preferSecure, ice_router, ice_secure, ice_timeout, ice_twoway
-
-
-
-
Method Detail
-
willAccept
void willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.
-
willAccept
void willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__ctx
- The Context map to send with the invocation.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__ctx
- The Context map to send with the invocation.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, Ice.Callback __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, Callback_Processor_willAccept __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_willAccept __cb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_willAccept
Ice.AsyncResult begin_willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
end_willAccept
void end_willAccept(Ice.AsyncResult __result)
Called bySharedResources
to find a suitable target foromero.grid.SharedResources.acquireProcessor
. New processor instances are added to the checklist by usingomero.grid.SharedResources.addProcessor
. All processors must respond with their session uuid in order to authorize the action.- Parameters:
__result
- The asynchronous result object.
-
requestRunning
void requestRunning(ProcessorCallbackPrx cb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
-
requestRunning
void requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__ctx
- The Context map to send with the invocation.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__ctx
- The Context map to send with the invocation.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, Ice.Callback __cb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, Callback_Processor_requestRunning __cb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_requestRunning __cb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_requestRunning
Ice.AsyncResult begin_requestRunning(ProcessorCallbackPrx cb, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_VoidCallback __responseCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
end_requestRunning
void end_requestRunning(Ice.AsyncResult __result)
Used by servers to find out what jobs are still active. Response will be sent toProcessorCallback.responseRunning
- Parameters:
__result
- The asynchronous result object.
-
parseJob
JobParams parseJob(java.lang.String session, Job jobObject) throws ServerError
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Throws:
ServerError
-
parseJob
JobParams parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx) throws ServerError
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__ctx
- The Context map to send with the invocation.- Throws:
ServerError
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__ctx
- The Context map to send with the invocation.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, Ice.Callback __cb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, Callback_Processor_parseJob __cb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_parseJob __cb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_parseJob
Ice.AsyncResult begin_parseJob(java.lang.String session, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<JobParams> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
end_parseJob
JobParams end_parseJob(Ice.AsyncResult __result) throws ServerError
Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back intoprocessJob
- Parameters:
__result
- The asynchronous result object.- Throws:
ServerError
-
processJob
ProcessPrx processJob(java.lang.String session, JobParams params, Job jobObject) throws ServerError
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Throws:
ServerError
-
processJob
ProcessPrx processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx) throws ServerError
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__ctx
- The Context map to send with the invocation.- Throws:
ServerError
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__ctx
- The Context map to send with the invocation.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, Ice.Callback __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Ice.Callback __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, Callback_Processor_processJob __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, Callback_Processor_processJob __cb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__ctx
- The Context map to send with the invocation.__cb
- The asynchronous callback object.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.- Returns:
- The asynchronous result object.
-
begin_processJob
Ice.AsyncResult begin_processJob(java.lang.String session, JobParams params, Job jobObject, java.util.Map<java.lang.String,java.lang.String> __ctx, IceInternal.Functional_GenericCallback1<ProcessPrx> __responseCb, IceInternal.Functional_GenericCallback1<Ice.UserException> __userExceptionCb, IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb, IceInternal.Functional_BoolCallback __sentCb)
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__ctx
- The Context map to send with the invocation.__responseCb
- The lambda response callback.__userExceptionCb
- The lambda user exception callback.__exceptionCb
- The lambda exception callback.__sentCb
- The lambda sent callback.- Returns:
- The asynchronous result object.
-
end_processJob
ProcessPrx end_processJob(Ice.AsyncResult __result) throws ServerError
Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. Theparams
argument was created by a previously call toparseJob
.- Parameters:
__result
- The asynchronous result object.- Throws:
ServerError
-
-