ome.services.blitz.impl

Class JobHandleI

java.lang.Object

ome.services.blitz.impl.AbstractAmdServant

ome.services.blitz.impl.AbstractCloseableAmdServant

ome.services.blitz.impl.JobHandleI

All Implemented Interfaces:

omero.api._JobHandleOperations, omero.api._ServiceInterfaceOperations, omero.api._StatefulServiceInterfaceOperations, CloseableServant, org.springframework.context.ApplicationContextAware

public class JobHandleI
extends AbstractCloseableAmdServant
implements omero.api._JobHandleOperations

Implementation of the JobHandle service.

Since:

3.0-Beta4

Author:

Josh Moore, josh at glencoesoftware.com

See Also:

JobHandle

Field Summary

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

be, ctx, holder, invoker, log, service

Constructor Summary

Constructors

Constructor and Description
JobHandleI(JobHandle service, BlitzExecutor be)

Method Summary

Methods

Modifier and Type	Method and Description
void	attach_async(omero.api.AMD_JobHandle_attach __cb, long jobId, Ice.Current __current)
void	cancelJob_async(omero.api.AMD_JobHandle_cancelJob __cb, Ice.Current __current)
void	getJob_async(omero.api.AMD_JobHandle_getJob __cb, Ice.Current __current)
void	jobError_async(omero.api.AMD_JobHandle_jobError __cb, Ice.Current __current)
void	jobFinished_async(omero.api.AMD_JobHandle_jobFinished __cb, Ice.Current __current)
void	jobMessage_async(omero.api.AMD_JobHandle_jobMessage __cb, Ice.Current __current)
void	jobRunning_async(omero.api.AMD_JobHandle_jobRunning __cb, Ice.Current __current)
void	jobStatus_async(omero.api.AMD_JobHandle_jobStatus __cb, Ice.Current __current)
protected void	postClose(Ice.Current current) Should not throw any exceptions which should be detected by clients since it is called in a finally block after the client thread has been released.
protected void	preClose(Ice.Current current)
void	setMessage_async(omero.api.AMD_JobHandle_setMessage __cb, String message, Ice.Current __current)
void	setStatus_async(omero.api.AMD_JobHandle_setStatus __cb, String status, Ice.Current __current)
void	setStatusAndMessage_async(omero.api.AMD_JobHandle_setStatusAndMessage __cb, String status, omero.RString msg, Ice.Current __current)
void	submit_async(omero.api.AMD_JobHandle_submit __cb, omero.model.Job j, Ice.Current __current)

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

close_async, close

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

Methods inherited from interface omero.api._StatefulServiceInterfaceOperations

activate_async, close_async, getCurrentEventContext_async, passivate_async

Constructor Detail

JobHandleI

public JobHandleI(JobHandle service,
          BlitzExecutor be)

Method Detail

attach_async

public void attach_async(omero.api.AMD_JobHandle_attach __cb,
                long jobId,
                Ice.Current __current)
                  throws omero.ServerError

Specified by:

attach_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

cancelJob_async

public void cancelJob_async(omero.api.AMD_JobHandle_cancelJob __cb,
                   Ice.Current __current)
                     throws omero.ServerError

Specified by:

cancelJob_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

getJob_async

public void getJob_async(omero.api.AMD_JobHandle_getJob __cb,
                Ice.Current __current)
                  throws omero.ServerError

Specified by:

getJob_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

jobError_async

public void jobError_async(omero.api.AMD_JobHandle_jobError __cb,
                  Ice.Current __current)
                    throws omero.ServerError

Specified by:

jobError_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

jobFinished_async

public void jobFinished_async(omero.api.AMD_JobHandle_jobFinished __cb,
                     Ice.Current __current)
                       throws omero.ServerError

Specified by:

jobFinished_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

jobMessage_async

public void jobMessage_async(omero.api.AMD_JobHandle_jobMessage __cb,
                    Ice.Current __current)
                      throws omero.ServerError

Specified by:

jobMessage_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

jobRunning_async

public void jobRunning_async(omero.api.AMD_JobHandle_jobRunning __cb,
                    Ice.Current __current)
                      throws omero.ServerError

Specified by:

jobRunning_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

jobStatus_async

public void jobStatus_async(omero.api.AMD_JobHandle_jobStatus __cb,
                   Ice.Current __current)
                     throws omero.ServerError

Specified by:

jobStatus_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

submit_async

public void submit_async(omero.api.AMD_JobHandle_submit __cb,
                omero.model.Job j,
                Ice.Current __current)
                  throws omero.ServerError

Specified by:

submit_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

setStatus_async

public void setStatus_async(omero.api.AMD_JobHandle_setStatus __cb,
                   String status,
                   Ice.Current __current)
                     throws omero.ServerError

Specified by:

setStatus_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

setStatusAndMessage_async

public void setStatusAndMessage_async(omero.api.AMD_JobHandle_setStatusAndMessage __cb,
                             String status,
                             omero.RString msg,
                             Ice.Current __current)
                               throws omero.ServerError

Specified by:

setStatusAndMessage_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

setMessage_async

public void setMessage_async(omero.api.AMD_JobHandle_setMessage __cb,
                    String message,
                    Ice.Current __current)
                      throws omero.ServerError

Specified by:

setMessage_async in interface omero.api._JobHandleOperations

Throws:

omero.ServerError

preClose

protected void preClose(Ice.Current current)
                 throws Throwable

Specified by:

preClose in class AbstractCloseableAmdServant

Throws:

Throwable

postClose

protected void postClose(Ice.Current current)

Description copied from class: AbstractCloseableAmdServant

Should not throw any exceptions which should be detected by clients since it is called in a finally block after the client thread has been released.

Specified by:

postClose in class AbstractCloseableAmdServant