Uses of Interface
org.apache.flink.statefun.sdk.java.message.Message

Packages that use Message

Package	Description
org.apache.flink.statefun.e2e.smoke.java
org.apache.flink.statefun.sdk.java
org.apache.flink.statefun.sdk.java.message
org.apache.flink.statefun.sdk.java.testing

Uses of Message in org.apache.flink.statefun.e2e.smoke.java

Methods in org.apache.flink.statefun.e2e.smoke.java with parameters of type Message

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	CommandInterpreterFn.apply(Context context, Message message)
void	CommandInterpreter.interpret(ValueSpec<java.lang.Long> state, Context context, Message message)

Uses of Message in org.apache.flink.statefun.sdk.java

Methods in org.apache.flink.statefun.sdk.java with parameters of type Message

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	StatefulFunction.apply(Context context, Message argument) Applies an input message to this function.
void	Context.send(Message message) Sends out a Message to another function.
void	Context.sendAfter(java.time.Duration duration, Message message) Sends out a Message to another function, after a specified Duration delay.
void	Context.sendAfter(java.time.Duration duration, java.lang.String cancellationToken, Message message) Sends out a Message to another function, after a specified Duration delay.

Uses of Message in org.apache.flink.statefun.sdk.java.message

Classes in org.apache.flink.statefun.sdk.java.message that implement Message

Modifier and Type	Class and Description
class	MessageWrapper

Methods in org.apache.flink.statefun.sdk.java.message that return Message

Modifier and Type	Method and Description
Message	MessageBuilder.build()

Methods in org.apache.flink.statefun.sdk.java.message with parameters of type Message

Modifier and Type	Method and Description
static MessageBuilder	MessageBuilder.fromMessage(Message message)

Uses of Message in org.apache.flink.statefun.sdk.java.testing

Methods in org.apache.flink.statefun.sdk.java.testing that return Message

Modifier and Type	Method and Description
Message	SideEffects.SendAfterSideEffect.message()
Message	SideEffects.SendSideEffect.message()

Methods in org.apache.flink.statefun.sdk.java.testing with parameters of type Message

Modifier and Type	Method and Description
void	TestContext.send(Message message)
void	TestContext.sendAfter(java.time.Duration duration, Message message)
void	TestContext.sendAfter(java.time.Duration duration, java.lang.String cancellationToken, Message message)
static SideEffects.SendAfterSideEffect	SideEffects.sentAfter(java.time.Duration duration, Message message)
static SideEffects.SendSideEffect	SideEffects.sentMessage(Message message)

Constructors in org.apache.flink.statefun.sdk.java.testing with parameters of type Message

Constructor and Description
SendAfterSideEffect(java.time.Duration duration, Message message)
SendAfterSideEffect(java.time.Duration duration, Message message, java.lang.String cancellationToken)
SendSideEffect(Message message)