public class InboundDriverRouter extends java.lang.Object implements Router<InboundDriverMessage>
Router.Downstream<T>
Constructor and Description |
---|
InboundDriverRouter() |
Modifier and Type | Method and Description |
---|---|
void |
route(InboundDriverMessage message,
Router.Downstream<InboundDriverMessage> downstream)
Routes a given message to downstream
StatefulFunction s. |
public void route(InboundDriverMessage message, Router.Downstream<InboundDriverMessage> downstream)
Router
StatefulFunction
s. A single message may result in
multiple functions being invoked.route
in interface Router<InboundDriverMessage>
message
- the message to route.downstream
- used to invoke downstream functions.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.