org.apache.flink.statefun.flink.core.message

Class RoutableMessageBuilder

java.lang.Object

org.apache.flink.statefun.flink.core.message.RoutableMessageBuilder

public final class RoutableMessageBuilder
extends java.lang.Object

A RoutableMessage Builder.

Method Summary

Modifier and Type	Method and Description
RoutableMessage	build()
static RoutableMessageBuilder	builder()
RoutableMessageBuilder	withMessageBody(java.lang.Object payload)
RoutableMessageBuilder	withSourceAddress(Address from)
RoutableMessageBuilder	withSourceAddress(FunctionType functionType, java.lang.String id)
RoutableMessageBuilder	withTargetAddress(Address target)
RoutableMessageBuilder	withTargetAddress(FunctionType functionType, java.lang.String id)

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static RoutableMessageBuilder builder()

withTargetAddress

public RoutableMessageBuilder withTargetAddress(FunctionType functionType,
                                                java.lang.String id)

withTargetAddress

public RoutableMessageBuilder withTargetAddress(Address target)

withSourceAddress

public RoutableMessageBuilder withSourceAddress(FunctionType functionType,
                                                java.lang.String id)

withSourceAddress

public RoutableMessageBuilder withSourceAddress(@Nullable
                                                Address from)

withMessageBody

public RoutableMessageBuilder withMessageBody(java.lang.Object payload)

build

public RoutableMessage build()