Uses of Interface
io.streamthoughts.azkarra.api.streams.errors.StreamThreadExceptionHandler

Packages that use StreamThreadExceptionHandler

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.runtime.config
io.streamthoughts.azkarra.runtime.context.internal
io.streamthoughts.azkarra.runtime.env
io.streamthoughts.azkarra.runtime.streams.errors

Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.api

Methods in io.streamthoughts.azkarra.api that return types with arguments of type StreamThreadExceptionHandler

Modifier and Type	Method	Description
Supplier<StreamThreadExceptionHandler>	StreamsExecutionEnvironment.getStreamThreadExceptionHandler()	Gets the StreamThreadExceptionHandler.

Method parameters in io.streamthoughts.azkarra.api with type arguments of type StreamThreadExceptionHandler

Modifier and Type	Method	Description
StreamsExecutionEnvironment	StreamsExecutionEnvironment.setStreamThreadExceptionHandler(Supplier<StreamThreadExceptionHandler> handler)	Sets the StreamThreadExceptionHandler invoked when a StreamThread abruptly terminates due to an uncaught exception.

Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.config

Methods in io.streamthoughts.azkarra.runtime.config that return StreamThreadExceptionHandler

Modifier and Type	Method	Description
StreamThreadExceptionHandler	AzkarraContextConfig.getDefaultStreamsThreadExceptionHandler()

Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.context.internal

Classes in io.streamthoughts.azkarra.runtime.context.internal that implement StreamThreadExceptionHandler

Modifier and Type	Class	Description
static class	ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler	A delegating StreamThreadExceptionHandler which is not Configurable.

Methods in io.streamthoughts.azkarra.runtime.context.internal that return StreamThreadExceptionHandler

Modifier and Type	Method	Description
StreamThreadExceptionHandler	ContextAwareThreadExceptionHandlerSupplier.get()

Constructor parameters in io.streamthoughts.azkarra.runtime.context.internal with type arguments of type StreamThreadExceptionHandler

Constructor	Description
ContextAwareThreadExceptionHandlerSupplier(AzkarraContext context, GettableComponent<StreamThreadExceptionHandler> gettable)

Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.env

Methods in io.streamthoughts.azkarra.runtime.env that return types with arguments of type StreamThreadExceptionHandler

Modifier and Type	Method	Description
Supplier<StreamThreadExceptionHandler>	DefaultStreamsExecutionEnvironment.getStreamThreadExceptionHandler()	Gets the StreamThreadExceptionHandler.

Method parameters in io.streamthoughts.azkarra.runtime.env with type arguments of type StreamThreadExceptionHandler

Modifier and Type	Method	Description
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.setStreamThreadExceptionHandler(Supplier<StreamThreadExceptionHandler> handler)	Sets the StreamThreadExceptionHandler invoked when a StreamThread abruptly terminates due to an uncaught exception.

Uses of StreamThreadExceptionHandler in io.streamthoughts.azkarra.runtime.streams.errors

Classes in io.streamthoughts.azkarra.runtime.streams.errors that implement StreamThreadExceptionHandler

Modifier and Type	Class	Description
class	CloseKafkaStreamsOnThreadException	Closes immediately the KafkaStreams instance when a StreamThread abruptly terminates due to an uncaught exception.
class	LogAndSkipOnThreadException	Logs and skips exception when a StreamThread abruptly terminates due to an uncaught exception.
class	RestartKafkaStreamsOnThreadException	Restarts the KafkaStreams instance when a StreamThread abruptly terminates due to an uncaught exception.