Package com.bakdata.kafka

Class KafkaApplication.RunnableApp<R extends Runner>

java.lang.Object

com.bakdata.kafka.KafkaApplication.RunnableApp<R>

Type Parameters:

R - type of Runner used by this app

All Implemented Interfaces:

AutoCloseable

Enclosing class:

KafkaApplication<R extends Runner,CR extends CleanUpRunner,O,E extends ExecutableApp<R,CR,O>,CA extends ConfiguredApp<E>,T,A,AC>

public static final class KafkaApplication.RunnableApp<R extends Runner>
extends Object
implements AutoCloseable

Provides access to a Runner and closes the associated ExecutableApp

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RunnableApp(@NonNull ExecutableApp<?,?,?> app, R runner, @NonNull Consumer<com.bakdata.kafka.KafkaApplication.Stoppable> onClose)

Method Summary

Modifier and Type	Method	Description
void	close()
R	getRunner()
void	stop()	Close the runner and app

Methods inherited from class java.lang.Object

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

Constructor Details

RunnableApp

protected RunnableApp(@NonNull
 @NonNull ExecutableApp<?,?,?> app,
 @NonNull
 R runner,
 @NonNull
 @NonNull Consumer<com.bakdata.kafka.KafkaApplication.Stoppable> onClose)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

stop

public void stop()

Close the runner and app

getRunner

@NonNull
public R getRunner()