Class OutboundMessageKafkaKeyEnricher<TMessage>

A generic enricher that sets the kafka key according to a value provider function.

Inheritance

System.Object

GenericOutboundHeadersEnricher<TMessage>

OutboundMessageKafkaKeyEnricher<TMessage>

Implements

IOutboundMessageEnricher

Inherited Members

GenericOutboundHeadersEnricher<TMessage>.Enrich(IOutboundEnvelope)

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: Silverback.Messaging.Outbound.Enrichers

Assembly: Silverback.Integration.Kafka.dll

Syntax

public class OutboundMessageKafkaKeyEnricher<TMessage> : GenericOutboundHeadersEnricher<TMessage>, IOutboundMessageEnricher where TMessage : class

Type Parameters

Name	Description
TMessage	The type of the messages to be enriched.

Constructors

OutboundMessageKafkaKeyEnricher(Func<IOutboundEnvelope<TMessage>, Object>)

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

Declaration

public OutboundMessageKafkaKeyEnricher(Func<IOutboundEnvelope<TMessage>, object> valueProvider)

Parameters

Type	Name	Description
System.Func<IOutboundEnvelope<TMessage>, System.Object>	valueProvider	The kafka key value provider function.

Implements

IOutboundMessageEnricher