Skip to content

Commit

Permalink
Create v3
Browse files Browse the repository at this point in the history
  • Loading branch information
philipp94831 committed Apr 19, 2024
1 parent 96e2dad commit af81485
Showing 1 changed file with 27 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -152,12 +152,22 @@ private static String[] addEnvironmentVariablesArguments(final String[] args) {

/**
* Create a new app that will be configured and executed according to this application.
*
* @param cleanUp whether app is created for clean up purposes. In that case, the user might want
* to skip initialization of expensive resources.
* @return app
*/
public abstract A createApp(boolean cleanUp);

/**
* Create a new app that will be configured and executed according to this application.
*
* @return app
*/
public A createApp() {
return this.createApp(false);
}

/**
* Clean all resources associated with this application
*/
Expand Down Expand Up @@ -203,6 +213,15 @@ public KafkaEndpointConfig getEndpointConfig() {

/**
* Create a new {@code ExecutableApp} that will be executed according to the requested command.
* @return {@code ExecutableApp}
*/
public final E createExecutableApp() {
return this.createExecutableApp(false);
}

/**
* Create a new {@code ExecutableApp} that will be executed according to the requested command.
*
* @param cleanUp whether app is created for clean up purposes. In that case, the user might want to skip
* initialization of expensive resources.
* @return {@code ExecutableApp}
Expand All @@ -213,6 +232,14 @@ public final E createExecutableApp(final boolean cleanUp) {
return configuredStreamsApp.withEndpoint(endpointConfig);
}

/**
* Create a new {@code ConfiguredApp} that will be executed according to this application.
* @return {@code ConfiguredApp}
*/
public final CA createConfiguredApp() {
return this.createConfiguredApp(false);
}

/**
* Create a new {@code ConfiguredApp} that will be executed according to this application.
*
Expand Down

0 comments on commit af81485

Please sign in to comment.