Package com.bakdata.kafka

Class KafkaApplication.CleanableApp<CR extends CleanUpRunner>

java.lang.Object

com.bakdata.kafka.KafkaApplication.CleanableApp<CR>

Type Parameters:

CR - type of CleanUpRunner 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 class KafkaApplication.CleanableApp<CR extends CleanUpRunner>
extends Object
implements AutoCloseable

Provides access to a CleanUpRunner and closes the associated ExecutableApp

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CleanableApp(@NonNull ExecutableApp<?,?,?> app, CR cleanUpRunner, @NonNull Consumer<com.bakdata.kafka.KafkaApplication.Stoppable> onClose)

Method Summary

Modifier and Type	Method	Description
void	close()
CR	getCleanUpRunner()
void	stop()	Close the app

Methods inherited from class java.lang.Object

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

Constructor Details

CleanableApp

protected CleanableApp(@NonNull
 @NonNull ExecutableApp<?,?,?> app,
 @NonNull
 CR cleanUpRunner,
 @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 app

getCleanUpRunner

@NonNull
public CR getCleanUpRunner()