Modifier and Type | Field and Description |
---|---|
PropertiesBuilder.BuildSteps |
ActionAppContext.propertiesBuilder |
Modifier and Type | Method and Description |
---|---|
StreamBuildResult |
ActionApp.build(PropertiesBuilder.BuildSteps properties)
Builds the stream.
|
void |
ActionApp.run(PropertiesBuilder.BuildSteps properties)
Builds and runs the stream.
|
Modifier and Type | Method and Description |
---|---|
static <A> SagaClientBuilder<A> |
SagaClientBuilder.create(PropertiesBuilder.BuildSteps configBuildSteps)
Create saga client builder with config properties.
|
SagaClientBuilder<A> |
SagaClientBuilder.withProperties(PropertiesBuilder.BuildSteps configBuildSteps)
Sets the config properties.
|
Modifier and Type | Method and Description |
---|---|
static <A> SagaApp<A> |
SagaApp.of(SagaSpec<A> sagaSpec,
ActionSpec<A> actionSpec,
TopicConfigBuilder.BuildSteps topicBuildFn,
PropertiesBuilder.BuildSteps propertiesBuildFn)
Static constructor for a
SagaApp saga coordinator application. |
Modifier and Type | Field and Description |
---|---|
PropertiesBuilder.BuildSteps |
StreamBuildContext.properties |
Modifier and Type | Method and Description |
---|---|
StreamBuildResult |
StreamApp.build(PropertiesBuilder.BuildSteps properties) |
void |
StreamApp.run(PropertiesBuilder.BuildSteps properties)
Run the SourcingApp with the given configuration steps
|
Modifier and Type | Method and Description |
---|---|
default PropertiesBuilder.BuildSteps |
PropertiesBuilder.BuildSteps.withInitialStep(PropertiesBuilder.BuildSteps initial) |
default PropertiesBuilder.BuildSteps |
PropertiesBuilder.BuildSteps.withNextStep(PropertiesBuilder.BuildSteps initial) |
Modifier and Type | Method and Description |
---|---|
default PropertiesBuilder.BuildSteps |
PropertiesBuilder.BuildSteps.withInitialStep(PropertiesBuilder.BuildSteps initial) |
default PropertiesBuilder.BuildSteps |
PropertiesBuilder.BuildSteps.withNextStep(PropertiesBuilder.BuildSteps initial) |
Copyright © 2019. All rights reserved.