Table of Contents

Class StreamsUncaughtExceptionHandler

Namespace
Org.Apache.Kafka.Streams.Errors
Assembly
MASES.KNet.dll

Listener for Kafka StreamsUncaughtExceptionHandler. Extends JVMBridgeListener, implements IStreamsUncaughtExceptionHandler

public class StreamsUncaughtExceptionHandler : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IStreamsUncaughtExceptionHandler, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
StreamsUncaughtExceptionHandler
Implements
Derived
Inherited Members

Remarks

Dispose the object to avoid a resource leak, the object contains a reference to the corresponding JVM object

Constructors

StreamsUncaughtExceptionHandler()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public StreamsUncaughtExceptionHandler()

StreamsUncaughtExceptionHandler(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public StreamsUncaughtExceptionHandler(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

OnHandle

public Func<JVMBridgeException, StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse> OnHandle { get; set; }

Property Value

Func<JVMBridgeException, StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse>

Remarks

If OnHandle has a value it takes precedence over corresponding class method

Methods

Handle(JVMBridgeException)

public virtual StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse Handle(JVMBridgeException arg0)

Parameters

arg0 JVMBridgeException

Throwable

Returns

StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse

StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse

InitializeHandlers()

Handlers initializer for StreamsUncaughtExceptionHandler

protected virtual void InitializeHandlers()