Package gda.commandqueue

Class CommandProcess

java.lang.Object

org.eclipse.scanning.api.event.core.AbstractLockingPausableProcess<CommandBean>

gda.commandqueue.CommandProcess

All Implemented Interfaces:

IBeanProcess<CommandBean>, IPublishable<CommandBean>

public class CommandProcess
extends AbstractLockingPausableProcess<CommandBean>

Implementation of IBeanProcess for running a Command. This allows a command for the old command queue to be run on the new GDA9 queue.

Field Summary

Fields inherited from class org.eclipse.scanning.api.event.core.AbstractLockingPausableProcess

bean, out, publisher

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CommandProcess(CommandBean bean, IPublisher<CommandBean> publisher)

Method Summary

Modifier and Type	Method	Description
protected void	doPause()	Override this method to do work on a pause once the pause lock has been received.
protected void	doResume()	Override this method to do work on a resume once the pause lock has been received.
protected void	doTerminate()
void	execute()	Execute the process, if an exception is thrown the process is set to failed and the message is the message of the exception.

Methods inherited from class org.eclipse.scanning.api.event.core.AbstractLockingPausableProcess

broadcast, checkPaused, dryRun, dryRun, dryRun, getBean, getPublisher, getUnique, isCancelled, isPaused, isWindowsOS, pause, resume, setCancelled, setLoggingFile, setLoggingFile, terminate, writeProjectBean, writeProjectBean

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.scanning.api.event.core.IBeanProcess

isBlocking, start

Constructor Details

CommandProcess

protected CommandProcess(CommandBean bean,
 IPublisher<CommandBean> publisher)

Method Details

doPause

protected void doPause()
                throws Exception

Description copied from class: AbstractLockingPausableProcess

Override this method to do work on a pause once the pause lock has been received.

Overrides:

doPause in class AbstractLockingPausableProcess<CommandBean>

Throws:

Exception

doResume

protected void doResume()
                 throws Exception

Description copied from class: AbstractLockingPausableProcess

Override this method to do work on a resume once the pause lock has been received.

Overrides:

doResume in class AbstractLockingPausableProcess<CommandBean>

Throws:

Exception

doTerminate

protected void doTerminate()
                    throws Exception

Overrides:

doTerminate in class AbstractLockingPausableProcess<CommandBean>

Throws:

Exception

execute

public void execute()
             throws EventException,
InterruptedException

Description copied from interface: IBeanProcess

Execute the process, if an exception is thrown the process is set to failed and the message is the message of the exception. This is the blocking method to run the process. The start method will be called by the IJobQueue's consumer thread running the process and by default terminate is called in the same thread.

Throws:

EventException

InterruptedException