Class MockProducer
public class MockProducer : Producer, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, ICloseable, IAutoCloseable- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>MockProducer
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])JVMBridgeBase<AutoCloseable>.DynBridgeClazzJVMBridgeBase<AutoCloseable>.BridgeClazzJVMBridgeBase.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.Dispose()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
MockProducer()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public MockProducer()MockProducer(Cluster, bool, Partitioner, Serializer, Serializer)
public MockProducer(Cluster arg0, bool arg1, Partitioner arg2, Serializer arg3, Serializer arg4)Parameters
arg0Clusterarg1boolarg2Partitionerarg3Serializerarg4Serializer
MockProducer(Cluster, bool, Serializer, Serializer)
public MockProducer(Cluster arg0, bool arg1, Serializer arg2, Serializer arg3)Parameters
arg0Clusterarg1boolarg2Serializerarg3Serializer
MockProducer(bool, Partitioner, Serializer, Serializer)
public MockProducer(bool arg0, Partitioner arg1, Serializer arg2, Serializer arg3)Parameters
arg0boolarg1Partitionerarg2Serializerarg3Serializer
MockProducer(bool, Serializer, Serializer)
public MockProducer(bool arg0, Serializer arg1, Serializer arg2)Parameters
arg0boolarg1Serializerarg2Serializer
MockProducer(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 MockProducer(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
abortTransactionException
public RuntimeException abortTransactionException { get; set; }Property Value
beginTransactionException
public RuntimeException beginTransactionException { get; set; }Property Value
closeException
public RuntimeException closeException { get; set; }Property Value
commitTransactionException
public RuntimeException commitTransactionException { get; set; }Property Value
flushException
public RuntimeException flushException { get; set; }Property Value
initTransactionException
public RuntimeException initTransactionException { get; set; }Property Value
partitionsForException
public RuntimeException partitionsForException { get; set; }Property Value
sendException
public RuntimeException sendException { get; set; }Property Value
sendOffsetsToTransactionException
public RuntimeException sendOffsetsToTransactionException { get; set; }Property Value
Methods
AbortTransaction()
public void AbortTransaction()Exceptions
BeginTransaction()
public void BeginTransaction()Exceptions
Clear()
public void Clear()ClientInstanceId(Duration)
public Uuid ClientInstanceId(Duration arg0)Parameters
Returns
Close()
public void Close()Close(Duration)
public void Close(Duration arg0)Parameters
Closed()
public bool Closed()Returns
CommitCount()
public long CommitCount()Returns
CommitTransaction()
public void CommitTransaction()Exceptions
CompleteNext()
public bool CompleteNext()Returns
ConsumerGroupOffsetsHistory()
public List ConsumerGroupOffsetsHistory()Returns
DisableTelemetry()
public void DisableTelemetry()ErrorNext(JVMBridgeException)
public bool ErrorNext(JVMBridgeException arg0)Parameters
arg0JVMBridgeException
Returns
FenceProducer()
public void FenceProducer()Flush()
public void Flush()Flushed()
public bool Flushed()Returns
History()
public List History()Returns
InitTransactions()
public void InitTransactions()InjectTimeoutException(int)
public void InjectTimeoutException(int arg0)Parameters
Metrics()
public Map Metrics()Returns
PartitionsFor(String)
public List PartitionsFor(String arg0)Parameters
Returns
Send(ProducerRecord)
public Future Send(ProducerRecord arg0)Parameters
Returns
Send(ProducerRecord, Callback)
public Future Send(ProducerRecord arg0, Callback arg1)Parameters
arg0ProducerRecordarg1Callback
Returns
SendOffsetsToTransaction(Map, ConsumerGroupMetadata)
public void SendOffsetsToTransaction(Map arg0, ConsumerGroupMetadata arg1)Parameters
arg0Maparg1ConsumerGroupMetadata
Exceptions
SentOffsets()
public bool SentOffsets()Returns
SetClientInstanceId(Uuid)
public void SetClientInstanceId(Uuid arg0)Parameters
SetMockMetrics(MetricName, Metric)
public void SetMockMetrics(MetricName arg0, Metric arg1)Parameters
arg0MetricNamearg1Metric
TransactionAborted()
public bool TransactionAborted()Returns
TransactionCommitted()
public bool TransactionCommitted()Returns
TransactionInFlight()
public bool TransactionInFlight()Returns
TransactionInitialized()
public bool TransactionInitialized()Returns
UncommittedOffsets()
public Map UncommittedOffsets()Returns
UncommittedRecords()
public List UncommittedRecords()