public final class AutoRoutableProtobufRouter extends java.lang.Object implements Router<com.google.protobuf.Message>
Router
that recognizes messages of type AutoRoutable
.
For each incoming AutoRoutable
, this router forwards the wrapped payload to the
configured target addresses as a Protobuf Any
message.
Router.Downstream<T>
Constructor and Description |
---|
AutoRoutableProtobufRouter() |
Modifier and Type | Method and Description |
---|---|
void |
route(com.google.protobuf.Message message,
Router.Downstream<com.google.protobuf.Message> downstream)
Routes a given message to downstream
StatefulFunction s. |
public void route(com.google.protobuf.Message message, Router.Downstream<com.google.protobuf.Message> downstream)
Router
StatefulFunction
s. A single message may result in
multiple functions being invoked.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.