Class CorrelationDataOutboundHeadersEnricher<TMessage>

Namespace

Silverback.Messaging.Producing.Enrichers

Assembly

Silverback.Integration.MQTT.dll

The enricher that sets the correlation data header.

public class CorrelationDataOutboundHeadersEnricher<TMessage> : GenericOutboundHeadersEnricher<TMessage>, IOutboundMessageEnricher

Type Parameters

TMessage

The type of the messages to be enriched.

Inheritance

object

GenericOutboundHeadersEnricher<TMessage>

CorrelationDataOutboundHeadersEnricher<TMessage>

Implements

IOutboundMessageEnricher

Inherited Members

GenericOutboundHeadersEnricher<TMessage>.Enrich(IOutboundEnvelope)

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

CorrelationDataOutboundHeadersEnricher(byte[]?)

Initializes a new instance of the CorrelationDataOutboundHeadersEnricher<TMessage> class.

public CorrelationDataOutboundHeadersEnricher(byte[]? correlationData)

Parameters

correlationData byte[]

The correlation data.

CorrelationDataOutboundHeadersEnricher(Func<IOutboundEnvelope<TMessage>, byte[]?>)

Initializes a new instance of the CorrelationDataOutboundHeadersEnricher<TMessage> class.

public CorrelationDataOutboundHeadersEnricher(Func<IOutboundEnvelope<TMessage>, byte[]?> correlationDataProvider)

Parameters

correlationDataProvider Func<IOutboundEnvelope<TMessage>, byte[]>

The correlation data provider function.

CorrelationDataOutboundHeadersEnricher(Func<TMessage?, byte[]?>)

Initializes a new instance of the CorrelationDataOutboundHeadersEnricher<TMessage> class.

public CorrelationDataOutboundHeadersEnricher(Func<TMessage?, byte[]?> correlationDataProvider)

Parameters

correlationDataProvider Func<TMessage, byte[]>

The correlation data provider function.