org.gridgain.grid.streamer.router

Class GridStreamerRoundRobinEventRouter

java.lang.Object

org.gridgain.grid.streamer.GridStreamerEventRouterAdapter

org.gridgain.grid.streamer.router.GridStreamerRoundRobinEventRouter

All Implemented Interfaces:

GridStreamerEventRouter

public class GridStreamerRoundRobinEventRouter
extends GridStreamerEventRouterAdapter

Round robin router.

Constructor Summary

Constructors

Constructor and Description
GridStreamerRoundRobinEventRouter()

Method Summary

Methods

Modifier and Type	Method and Description
GridNode	route(GridStreamerContext ctx, String stageName, Object evt) Selects a node for given event that should be processed by a stage with given name.

Methods inherited from class org.gridgain.grid.streamer.GridStreamerEventRouterAdapter

route

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerRoundRobinEventRouter

public GridStreamerRoundRobinEventRouter()

Method Detail

route

public GridNode route(GridStreamerContext ctx,
             String stageName,
             Object evt)

Selects a node for given event that should be processed by a stage with given name.

Parameters:

ctx - Streamer context.

stageName - Stage name.

evt - Event to route.

Returns:

Node to route to. If this method returns null then the whole pipeline execution will be terminated. All running and ongoing stages for pipeline execution will be cancelled.