Class StandbyUpdateListener
public class StandbyUpdateListener : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IStandbyUpdateListener
- Inheritance
-
StandbyUpdateListener
- Implements
- Derived
- Inherited Members
Constructors
StandbyUpdateListener()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public StandbyUpdateListener()
StandbyUpdateListener(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public StandbyUpdateListener(IJVMBridgeBaseInitializer initializer)
Parameters
initializerIJVMBridgeBaseInitializer
StandbyUpdateListener(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 StandbyUpdateListener(params object[] args)
Parameters
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }
Property Value
OnOnBatchLoaded
public Action<TopicPartition, String, TaskId, long, long, long> OnOnBatchLoaded { get; set; }
Property Value
Remarks
If OnOnBatchLoaded has a value it takes precedence over corresponding class method
OnOnUpdateStart
public Action<TopicPartition, String, long> OnOnUpdateStart { get; set; }
Property Value
Remarks
If OnOnUpdateStart has a value it takes precedence over corresponding class method
OnOnUpdateSuspended
public Action<TopicPartition, String, long, long, StandbyUpdateListener.SuspendReason> OnOnUpdateSuspended { get; set; }
Property Value
Remarks
If OnOnUpdateSuspended has a value it takes precedence over corresponding class method
Methods
InitializeHandlers()
Handlers initializer for StandbyUpdateListener
protected virtual void InitializeHandlers()
OnBatchLoaded(TopicPartition, String, TaskId, long, long, long)
public virtual void OnBatchLoaded(TopicPartition arg0, String arg1, TaskId arg2, long arg3, long arg4, long arg5)
Parameters
OnUpdateStart(TopicPartition, String, long)
public virtual void OnUpdateStart(TopicPartition arg0, String arg1, long arg2)
Parameters
arg0TopicPartitionarg1Stringarg2long
OnUpdateSuspended(TopicPartition, String, long, long, SuspendReason)
public virtual void OnUpdateSuspended(TopicPartition arg0, String arg1, long arg2, long arg3, StandbyUpdateListener.SuspendReason arg4)
Parameters
arg0TopicPartitionarg1Stringarg2longarg3longarg4StandbyUpdateListener.SuspendReason