Class ProducerPool
Inheritance
object
ProducerPool
Inherited Members
object.GetType()
object.MemberwiseClone()
object.ToString()
object.Equals(object)
object.Equals(object, object)
object.ReferenceEquals(object, object)
object.GetHashCode()
Namespace: Volo.Abp.Kafka
Assembly: Volo.Abp.Kafka.dll
Syntax
public class ProducerPool : IProducerPool, IDisposable, ISingletonDependencyConstructors
ProducerPool(IOptions<AbpKafkaOptions>)
Declaration
public ProducerPool(IOptions<AbpKafkaOptions> options)Parameters
| Type | Name | Description |
|---|---|---|
| Microsoft.Extensions.Options.IOptions<TOptions><AbpKafkaOptions> | options |
Properties
DefaultTransactionsWaitDuration
Declaration
protected TimeSpan DefaultTransactionsWaitDuration { get; set; }Property Value
| Type | Description |
|---|---|
| System.TimeSpan |
Logger
Declaration
public ILogger<ProducerPool> Logger { get; set; }Property Value
| Type | Description |
|---|---|
| Microsoft.Extensions.Logging.ILogger<TCategoryName><ProducerPool> |
Options
Declaration
protected AbpKafkaOptions Options { get; }Property Value
| Type | Description |
|---|---|
| AbpKafkaOptions |
Producers
Declaration
protected ConcurrentDictionary<string, Lazy<IProducer<string, byte[]>>> Producers { get; }Property Value
| Type | Description |
|---|---|
| System.Collections.Concurrent.ConcurrentDictionary<TKey, TValue><string, System.Lazy<T><Confluent.Kafka.IProducer<,><string, byte[]>>> |
TotalDisposeWaitDuration
Declaration
protected TimeSpan TotalDisposeWaitDuration { get; set; }Property Value
| Type | Description |
|---|---|
| System.TimeSpan |
Methods
Dispose()
Declaration
public void Dispose()Get(string)
Declaration
public virtual IProducer<string, byte[]> Get(string connectionName = null)Parameters
| Type | Name | Description |
|---|---|---|
| string | connectionName |
Returns
| Type | Description |
|---|---|
| Confluent.Kafka.IProducer<,><string, byte[]> |
Implements
System.IDisposable