com.gigaspaces.grid.worker
Interface GigaSpaceWorker

All Superinterfaces:

java.lang.Runnable

All Known Implementing Classes:

AbstractSpaceWorker, TaskWorker

public interface GigaSpaceWorker
extends java.lang.Runnable

The GigaSpaceWorker interface defines the semantics of a worker entity that will process Entry objects from a GigaSpace.

Method Summary

org.jini.rio.watch.WatchRegistry	getWatchRegistry() Get the the WatchRegistry
void	setID(int id) Set the identifier for the GigaSpaceWorker
void	setSpace(net.jini.space.JavaSpace space) Set the JavaSpace for the worker.
void	setWatchRegistry(org.jini.rio.watch.WatchRegistry watchRegistry) Set the WatchRegistry
void	shutdown() The shutdown() method provides the ability to shutdown any processing that a GigaSpaceWorker At this time the shutdown method semantic does not distinguish between a hard shutdown (stop immediately regardless of what you're doing) or soft shutdown (exit gracefully by completing pending tasks.

Methods inherited from interface java.lang.Runnable

run

Method Detail

setSpace

void setSpace(net.jini.space.JavaSpace space)

Set the JavaSpace for the worker.

setWatchRegistry

void setWatchRegistry(org.jini.rio.watch.WatchRegistry watchRegistry)

Set the WatchRegistry

getWatchRegistry

org.jini.rio.watch.WatchRegistry getWatchRegistry()

Get the the WatchRegistry

setID

void setID(int id)

Set the identifier for the GigaSpaceWorker

shutdown

void shutdown()
              throws java.lang.InterruptedException

The shutdown() method provides the ability to shutdown any processing that a GigaSpaceWorker

At this time the shutdown method semantic does not distinguish between a hard shutdown (stop immediately regardless of what you're doing) or soft shutdown (exit gracefully by completing pending tasks.

Throws:

java.lang.InterruptedException