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

Class LogAndSkipOnThreadException

java.lang.Object

io.streamthoughts.azkarra.runtime.streams.errors.LogAndSkipOnThreadException

All Implemented Interfaces:

StreamThreadExceptionHandler

public class LogAndSkipOnThreadException
extends Object
implements StreamThreadExceptionHandler

Logs and skips exception when a StreamThread abruptly terminates due to an uncaught exception.

Constructor Summary

Constructors

Constructor	Description
LogAndSkipOnThreadException()

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 java.lang.Object

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

Constructor Detail

LogAndSkipOnThreadException

public LogAndSkipOnThreadException()

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.