Package io.streamthoughts.azkarra.runtime.streams.errors

Class CloseKafkaStreamsOnThreadException

java.lang.Object

io.streamthoughts.azkarra.runtime.streams.errors.CloseKafkaStreamsOnThreadException

All Implemented Interfaces:

StreamThreadExceptionHandler, StreamsExecutionEnvironmentAware

public class CloseKafkaStreamsOnThreadException
extends Object
implements StreamThreadExceptionHandler, StreamsExecutionEnvironmentAware

Closes immediately the KafkaStreams instance when a StreamThread abruptly terminates due to an uncaught exception.

Constructor Summary

Constructors

Constructor	Description
CloseKafkaStreamsOnThreadException()

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.
void	setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)	Set the StreamsExecutionEnvironment.

Methods inherited from class java.lang.Object

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

Constructor Detail

CloseKafkaStreamsOnThreadException

public CloseKafkaStreamsOnThreadException()

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.

setExecutionEnvironment

public void setExecutionEnvironment(StreamsExecutionEnvironment<?> environment)

Set the StreamsExecutionEnvironment.

Specified by:

setExecutionEnvironment in interface StreamsExecutionEnvironmentAware

Parameters:

environment - the StreamsExecutionEnvironment instance