Class ProducerConsumerTrigger<T>

Namespace

Common

Assembly

Lykke.Common.dll

Lykke producer-consumer implementation

public sealed class ProducerConsumerTrigger<T> : IProducerConsumerTrigger<T>, IStartStop, IStartable, IStopable, IDisposable where T : class

Type Parameters

T

Inheritance

object

ProducerConsumerTrigger<T>

Implements

IProducerConsumerTrigger<T>

IStartStop

IStartable

IStopable

IDisposable

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

JsonSerialisersExt.ToJson(object, bool)

PrivateInfoExt.HidePrivateInfo<T>(object)

ReflectionUtils.PopulateObject(object, Func<PropertyInfo, object>)

UrlUtils.FormatUrlString(object, params string[])

UrlUtils.ToUrlParamString(object, ILog, params string[])

UrlUtils.ToUrlParamString(object, params string[])

Constructors

ProducerConsumerTrigger(string, ILogFactory, ProducerConsumerConsumedEventHandler<T>, bool)

Creates Lykke producer-consumer implementation

public ProducerConsumerTrigger(string componentName, ILogFactory logFactory, ProducerConsumerConsumedEventHandler<T> handler = null, bool enableAppInisghtsMetric = false)

Parameters

componentName string

Name of the component, which will be used in the errors logging

logFactory ILogFactory

The log

handler ProducerConsumerConsumedEventHandler<T>

Handler which will be trigger every time, when item is consumed.

This is just shortcut to assign handler for Consumed

You do not need to catch exceptions just to for logging in handler of this event, infrastructure will do it for you.

enableAppInisghtsMetric bool

Enables Application Insight telemetry

Methods

Dispose()

Disposes the producer-consumer

public void Dispose()

Produce(T)

public void Produce(T item)

Parameters

item T

Start()

Starts the producer-consumer

public void Start()

Stop()

Stops the producer-consumer

public void Stop()

Events

Consumed

public event ProducerConsumerConsumedEventHandler<T> Consumed

Event Type

ProducerConsumerConsumedEventHandler<T>