Class ProducerInterceptor<K, V>
public class ProducerInterceptor<K, V> : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IProducerInterceptor<K, V>, IConfigurable, IAutoCloseableType Parameters
KV
- Inheritance
-
ProducerInterceptor<K, V>
- Implements
-
IProducerInterceptor<K, V>
- Derived
- Inherited Members
Constructors
ProducerInterceptor()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public ProducerInterceptor()ProducerInterceptor(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public ProducerInterceptor(IJVMBridgeBaseInitializer initializer)Parameters
initializerIJVMBridgeBaseInitializer
ProducerInterceptor(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 ProducerInterceptor(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<String, object>> OnConfigure { get; set; }Property Value
Remarks
If OnConfigure has a value it takes precedence over corresponding class method
OnOnAcknowledgement
public Action<RecordMetadata, JVMBridgeException, Headers> OnOnAcknowledgement { get; set; }Property Value
Remarks
If OnOnAcknowledgement has a value it takes precedence over corresponding class method
OnOnAcknowledgement2
public Action<RecordMetadata, JVMBridgeException> OnOnAcknowledgement2 { get; set; }Property Value
Remarks
If OnOnAcknowledgement2 has a value it takes precedence over corresponding class method
OnOnSend
public Func<ProducerRecord<K, V>, ProducerRecord<K, V>> OnOnSend { get; set; }Property Value
- Func<ProducerRecord<K, V>, ProducerRecord<K, V>>
Remarks
If OnOnSend has a value it takes precedence over corresponding class method
Methods
Close()
public virtual void Close()Configure(Map<String, object>)
public virtual void Configure(Map<String, object> arg0)Parameters
InitializeHandlers()
Handlers initializer for ProducerInterceptor
protected virtual void InitializeHandlers()OnAcknowledgement(RecordMetadata, JVMBridgeException)
public virtual void OnAcknowledgement(RecordMetadata arg0, JVMBridgeException arg1)Parameters
Remarks
The method invokes the default implementation in the JVM interface using OnAcknowledgementDefault(RecordMetadata, JVMBridgeException, Headers); override the method to implement a different behavior
OnAcknowledgement(RecordMetadata, JVMBridgeException, Headers)
public virtual void OnAcknowledgement(RecordMetadata arg0, JVMBridgeException arg1, Headers arg2)Parameters
arg0RecordMetadataarg1JVMBridgeExceptionarg2Headers
Remarks
The method invokes the default implementation in the JVM interface using OnAcknowledgementDefault(RecordMetadata, JVMBridgeException, Headers); override the method to implement a different behavior
OnAcknowledgementDefault(RecordMetadata, JVMBridgeException)
public void OnAcknowledgementDefault(RecordMetadata arg0, JVMBridgeException arg1)Parameters
Remarks
The method invokes the default implementation in the JVM interface
OnAcknowledgementDefault(RecordMetadata, JVMBridgeException, Headers)
public void OnAcknowledgementDefault(RecordMetadata arg0, JVMBridgeException arg1, Headers arg2)Parameters
arg0RecordMetadataarg1JVMBridgeExceptionarg2Headers
Remarks
The method invokes the default implementation in the JVM interface
OnSend(ProducerRecord<K, V>)
public virtual ProducerRecord<K, V> OnSend(ProducerRecord<K, V> arg0)Parameters
arg0ProducerRecord<K, V>
Returns
- ProducerRecord<K, V>