Package io.streamthoughts.azkarra.runtime.context.internal

Class ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler

java.lang.Object

io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware<StreamThreadExceptionHandler>

io.streamthoughts.azkarra.runtime.context.internal.ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler

All Implemented Interfaces:

StreamThreadExceptionHandler, StreamsExecutionEnvironmentAware

Enclosing class:

ContextAwareThreadExceptionHandlerSupplier

public static class ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler
extends DelegatingExecutionEnvironmentAware<StreamThreadExceptionHandler>
implements StreamThreadExceptionHandler

A delegating StreamThreadExceptionHandler which is not Configurable.

Method Summary

Modifier and Type	Method	Description
void	handle(KafkaStreamsContainer container, Thread streamThread, Throwable e)	Method invoked when a StreamThread abruptly terminates due to an uncaught exception.

Methods inherited from class io.streamthoughts.azkarra.runtime.context.internal.DelegatingExecutionEnvironmentAware

setExecutionEnvironment

Methods inherited from class java.lang.Object

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

Method Detail

handle

public void handle(KafkaStreamsContainer container,
                   Thread streamThread,
                   Throwable e)

Method invoked when a StreamThread abruptly terminates due to an uncaught exception.

Specified by:

handle in interface StreamThreadExceptionHandler

Parameters:

container - the streams container.

streamThread - the thread.

e - the exception.