org.gridgain.grid.kernal.processors.streamer

Class GridStreamProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.streamer.GridStreamProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridStreamProcessor
extends GridProcessorAdapter

Field Summary

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

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridStreamProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
void	onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	onUndeployed(UUID leftNodeId, ClassLoader ldr) Callback for undeployed class loaders.
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
GridStreamer	streamer()
GridStreamer	streamer(String name)
Collection<GridStreamer>	streamers()

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

assertParameter, collectDiscoveryData, onDiscoveryDataReceived, printMemoryStats, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamProcessor

public GridStreamProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

onKernalStart

public void onKernalStart()
                   throws GridException

Callback that notifies that kernal has successfully started, including all managers and processors.

Specified by:

onKernalStart in interface GridComponent

Overrides:

onKernalStart in class GridProcessorAdapter

Throws:

GridException - Thrown in case of any errors.

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.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

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.

addAttributes

public void addAttributes(Map<String,Object> attrs)
                   throws GridException

Adds attributes from this component to map of all node attributes.

Specified by:

addAttributes in interface GridProcessor

Overrides:

addAttributes in class GridProcessorAdapter

Parameters:

attrs - Map of all attributes.

Throws:

GridException - If failed.

streamer

public GridStreamer streamer()

Returns:

Default no-name streamer.

streamer

public GridStreamer streamer(@Nullable
                    String name)

Parameters:

name - Streamer name.

Returns:

Streamer for given name.

streamers

public Collection<GridStreamer> streamers()

Returns:

All configured streamers.

onUndeployed

public void onUndeployed(UUID leftNodeId,
                ClassLoader ldr)

Callback for undeployed class loaders.

Parameters:

leftNodeId - Left node ID.

ldr - Class loader.