Table of Contents

Class Callback

Namespace
Org.Apache.Kafka.Clients.Producer
Assembly
MASES.KNet.dll

Listener for Kafka Callback. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements ICallback

public class Callback : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, ICallback, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
Callback
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

Callback()

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

public Callback()

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

OnOnCompletion

public Action<RecordMetadata, JVMBridgeException> OnOnCompletion { get; set; }

Property Value

Action<RecordMetadata, JVMBridgeException>

Remarks

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

Methods

InitializeHandlers()

Handlers initializer for Callback

protected virtual void InitializeHandlers()

OnCompletion(RecordMetadata, JVMBridgeException)

public virtual void OnCompletion(RecordMetadata arg0, JVMBridgeException arg1)

Parameters

arg0 RecordMetadata

RecordMetadata

arg1 JVMBridgeException

Exception