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
RaftClient.Listener
Implements
Derived
Inherited Members

Constructors

Listener()

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

public Listener()

Listener(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 Listener(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

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()