Class ConsumerInterceptor
public class ConsumerInterceptor : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition- Inheritance
-
ConsumerInterceptor
- Implements
- Derived
- Inherited Members
Constructors
ConsumerInterceptor()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public ConsumerInterceptor()ConsumerInterceptor(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public ConsumerInterceptor(IJVMBridgeBaseInitializer initializer)Parameters
initializerIJVMBridgeBaseInitializer
ConsumerInterceptor(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 ConsumerInterceptor(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
OnClose
public Action OnClose { get; set; }Property Value
Remarks
If OnClose has a value it takes precedence over corresponding class method
OnConfigure
public Action<Map> OnConfigure { get; set; }Property Value
Remarks
If OnConfigure has a value it takes precedence over corresponding class method
OnOnCommit
public Action<Map> OnOnCommit { get; set; }Property Value
Remarks
If OnOnCommit has a value it takes precedence over corresponding class method
OnOnConsume
public Func<ConsumerRecords, ConsumerRecords> OnOnConsume { get; set; }Property Value
Remarks
If OnOnConsume has a value it takes precedence over corresponding class method
Methods
Close()
public virtual void Close()Configure(Map)
public virtual void Configure(Map arg0)Parameters
InitializeHandlers()
Handlers initializer for ConsumerInterceptor
protected virtual void InitializeHandlers()OnCommit(Map)
public virtual void OnCommit(Map arg0)Parameters
OnConsume(ConsumerRecords)
public virtual ConsumerRecords OnConsume(ConsumerRecords arg0)