Package io.streamthoughts.azkarra.api.streams.errors

Class DelegatingUncaughtExceptionHandler

java.lang.Object

io.streamthoughts.azkarra.api.streams.errors.DelegatingUncaughtExceptionHandler

All Implemented Interfaces:

Thread.UncaughtExceptionHandler

public class DelegatingUncaughtExceptionHandler
extends Object
implements Thread.UncaughtExceptionHandler

This class can be used to delegate Thread.UncaughtExceptionHandler exception handling to an a given StreamThreadExceptionHandler implementation.

See Also:

StreamThreadExceptionHandler

Constructor Summary

Constructors

Constructor	Description
DelegatingUncaughtExceptionHandler(KafkaStreamsContainer container, StreamThreadExceptionHandler handler)

Method Summary

Modifier and Type	Method	Description
void	uncaughtException(Thread t, Throwable e)

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingUncaughtExceptionHandler

public DelegatingUncaughtExceptionHandler(KafkaStreamsContainer container,
                                          StreamThreadExceptionHandler handler)

Method Detail

uncaughtException

public void uncaughtException(Thread t,
                              Throwable e)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler