Table of Contents

Class RaftClient.Listener

Namespace
Org.Apache.Kafka.Raft
Assembly
MASES.KNet.dll
public class RaftClient.Listener : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
RaftClient.Listener
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

Constructors

Listener()

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

public Listener()

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

OnBeginShutdown

public Action OnBeginShutdown { get; set; }

Property Value

Action

Remarks

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

OnHandleCommit

public Action<BatchReader> OnHandleCommit { get; set; }

Property Value

Action<BatchReader>

Remarks

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

OnHandleLeaderChange

public Action<LeaderAndEpoch> OnHandleLeaderChange { get; set; }

Property Value

Action<LeaderAndEpoch>

Remarks

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

OnHandleLoadSnapshot

public Action<SnapshotReader> OnHandleLoadSnapshot { get; set; }

Property Value

Action<SnapshotReader>

Remarks

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

Methods

BeginShutdown()

public virtual void BeginShutdown()

Remarks

The method invokes the default implementation in the JVM interface using BeginShutdownDefault(); override the method to implement a different behavior

BeginShutdownDefault()

public void BeginShutdownDefault()

Remarks

The method invokes the default implementation in the JVM interface

HandleCommit(BatchReader)

public virtual void HandleCommit(BatchReader arg0)

Parameters

arg0 BatchReader

BatchReader

HandleLeaderChange(LeaderAndEpoch)

public virtual void HandleLeaderChange(LeaderAndEpoch arg0)

Parameters

arg0 LeaderAndEpoch

LeaderAndEpoch

Remarks

The method invokes the default implementation in the JVM interface using HandleLeaderChangeDefault(LeaderAndEpoch); override the method to implement a different behavior

HandleLeaderChangeDefault(LeaderAndEpoch)

public void HandleLeaderChangeDefault(LeaderAndEpoch arg0)

Parameters

arg0 LeaderAndEpoch

LeaderAndEpoch

Remarks

The method invokes the default implementation in the JVM interface

HandleLoadSnapshot(SnapshotReader)

public virtual void HandleLoadSnapshot(SnapshotReader arg0)

Parameters

arg0 SnapshotReader

SnapshotReader

InitializeHandlers()

Handlers initializer for RaftClient.Listener

protected virtual void InitializeHandlers()