Package gda.commandqueue

Interface Processor

All Superinterfaces:

gda.observable.IObservable

All Known Subinterfaces:

IFindableQueueProcessor

All Known Implementing Classes:

FindableProcessorQueue

public interface Processor
extends gda.observable.IObservable

Processor handles the processing of a collection of items, one item at a time. The processing can be started, stopped and paused The processor can be skip the processing of the current item, ProcessListeners can register for updates on changes to the state of the processor.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	Processor.STATE

Method Summary

Modifier and Type	Method	Description
ProcessorCurrentItem	getCurrentItem()
Processor.STATE	getState()
void	passBaton(String receiverUsername, int receiverIndex)
void	pause(long timeout_ms)
void	skip(long timeout_ms)
void	start(long timeout_ms)
void	stop(long timeout_ms)
void	stopAfterCurrent()

Methods inherited from interface gda.observable.IObservable

addIObserver, deleteIObserver, deleteIObservers

Method Details

stop

void stop(long timeout_ms)
   throws Exception

Throws:

Exception

pause

void pause(long timeout_ms)
    throws Exception

Throws:

Exception

skip

void skip(long timeout_ms)
   throws Exception

Throws:

Exception

start

void start(long timeout_ms)
    throws Exception

Throws:

Exception

stopAfterCurrent

void stopAfterCurrent()
               throws Exception

Throws:

Exception

getState

Processor.STATE getState()

getCurrentItem

ProcessorCurrentItem getCurrentItem()
                             throws Exception

Throws:

Exception

passBaton

void passBaton(String receiverUsername,
 int receiverIndex)
        throws Exception

Throws:

Exception