Table of Contents

Class KafkaStreams.StateListener

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

Listener for Kafka StateListener. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements KafkaStreams.IStateListener

public class KafkaStreams.StateListener : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, KafkaStreams.IStateListener, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
KafkaStreams.StateListener
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeListener.Dispose()
JVMBridgeListener.AutoInit
JVMBridgeListener.IsBridgeStatic
JVMBridgeListener.IsBridgeCloseable
JVMBridgeListener.IsBridgeListener
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()
JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])
JVMBridgeBase<JVMBridgeListener>.DynBridgeClazz
JVMBridgeBase<JVMBridgeListener>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeInterface
JVMBridgeBase.IsBridgeAbstract

Remarks

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

Constructors

StateListener()

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

public StateListener()

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

OnOnChange

public Action<KafkaStreams.State, KafkaStreams.State> OnOnChange { get; set; }

Property Value

Action<KafkaStreams.State, KafkaStreams.State>

Remarks

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

Methods

InitializeHandlers()

Handlers initializer for KafkaStreams.StateListener

protected virtual void InitializeHandlers()

OnChange(State, State)

public virtual void OnChange(KafkaStreams.State arg0, KafkaStreams.State arg1)

Parameters

arg0 KafkaStreams.State

KafkaStreams.State

arg1 KafkaStreams.State

KafkaStreams.State