org.apache.flink.statefun.e2e.smoke.driver

Class CommandRouter

java.lang.Object

org.apache.flink.statefun.e2e.smoke.driver.CommandRouter

All Implemented Interfaces:

Router<TypedValue>

public class CommandRouter
extends java.lang.Object
implements Router<TypedValue>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.statefun.sdk.io.Router

Router.Downstream<T>

Constructor Summary

Constructors

Constructor and Description
CommandRouter(Ids ids)

Method Summary

Modifier and Type	Method and Description
void	route(TypedValue command, Router.Downstream<TypedValue> downstream) Routes a given message to downstream StatefulFunctions.

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandRouter

public CommandRouter(Ids ids)

Method Detail

route

public void route(TypedValue command,
                  Router.Downstream<TypedValue> downstream)

Description copied from interface: Router

Routes a given message to downstream StatefulFunctions. A single message may result in multiple functions being invoked.

Specified by:

route in interface Router<TypedValue>

Parameters:

command - the message to route.

downstream - used to invoke downstream functions.