Package | Description |
---|---|
org.apache.flink.statefun.sdk.java | |
org.apache.flink.statefun.sdk.java.message | |
org.apache.flink.statefun.sdk.java.testing |
Modifier and Type | Method and Description |
---|---|
Address |
Context.self() |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<Address> |
Context.caller() |
Modifier and Type | Method and Description |
---|---|
Address |
Message.targetAddress() |
Address |
MessageWrapper.targetAddress() |
Modifier and Type | Method and Description |
---|---|
static MessageBuilder |
MessageBuilder.forAddress(Address address) |
MessageBuilder |
MessageBuilder.withTargetAddress(Address targetAddress) |
Constructor and Description |
---|
MessageWrapper(Address targetAddress,
TypedValue typedValue) |
Modifier and Type | Method and Description |
---|---|
Address |
TestContext.self() |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<Address> |
TestContext.caller() |
Modifier and Type | Method and Description |
---|---|
static TestContext |
TestContext.forTarget(Address self) |
static TestContext |
TestContext.forTargetWithCaller(Address self,
Address caller) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.