org.gridgain.grid.kernal.processors.continuous

Class GridContinuousProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.continuous.GridContinuousProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridContinuousProcessor
extends GridProcessorAdapter

Processor for continuous routines.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridContinuousProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addNotification(UUID nodeId, UUID routineId, Object obj, Object orderedTopic)
Object	collectDiscoveryData(UUID nodeId) Gets discovery data object that will be sent to new node during discovery process.
void	onDiscoveryDataReceived(Object obj) Receives discovery data object from remote nodes (called on new node during discovery process).
void	start() Starts grid component.
GridFuture<UUID>	startRoutine(GridContinuousHandler hnd, int bufSize, long interval, boolean autoUnsubscribe, GridPredicate<GridNode> prjPred)
void	stop(boolean cancel) Stops grid component.
GridFuture<?>	stopRoutine(UUID routineId)

Methods inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

addAttributes, assertParameter, onKernalStart, onKernalStop, printMemoryStats, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridContinuousProcessor

public GridContinuousProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws GridException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

GridException - Throws in case of any errors.

stop

public void stop(boolean cancel)
          throws GridException

Stops grid component.

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

GridException - Thrown in case of any errors.

collectDiscoveryData

@Nullable
public Object collectDiscoveryData(UUID nodeId)

Gets discovery data object that will be sent to new node during discovery process.

Specified by:

collectDiscoveryData in interface GridComponent

Overrides:

collectDiscoveryData in class GridProcessorAdapter

Parameters:

nodeId - ID of new node that joins topology.

Returns:

Discovery data object or null if there is nothing to send for this component.

onDiscoveryDataReceived

public void onDiscoveryDataReceived(Object obj)

Receives discovery data object from remote nodes (called on new node during discovery process).

Specified by:

onDiscoveryDataReceived in interface GridComponent

Overrides:

onDiscoveryDataReceived in class GridProcessorAdapter

Parameters:

obj - Discovery data object or null if nothing was sent for this component.

startRoutine

public GridFuture<UUID> startRoutine(GridContinuousHandler hnd,
                            int bufSize,
                            long interval,
                            boolean autoUnsubscribe,
                            @Nullable
                            GridPredicate<GridNode> prjPred)

Parameters:

hnd - Handler.

bufSize - Buffer size.

interval - Time interval.

autoUnsubscribe - Automatic unsubscribe flag.

prjPred - Projection predicate.

Returns:

Future.

stopRoutine

public GridFuture<?> stopRoutine(UUID routineId)

Parameters:

routineId - Consume ID.

Returns:

Future.

addNotification

public void addNotification(UUID nodeId,
                   UUID routineId,
                   @Nullable
                   Object obj,
                   @Nullable
                   Object orderedTopic)
                     throws GridException

Parameters:

nodeId - ID of the node that started routine.

routineId - Routine ID.

obj - Notification object.

orderedTopic - Topic for ordered notifications. If null, non-ordered message will be sent.

Throws:

GridException - In case of error.