Class CloudEventMapper

Namespace: Momentum.Extensions.Messaging.Kafka
Assembly: Momentum.Extensions.Messaging.Kafka.dll

public class CloudEventMapper : IKafkaEnvelopeMapper, IEnvelopeMapper<Message<string, byte[]>, Message<string, byte[]>>, IOutgoingMapper<Message<string, byte[]>>, IIncomingMapper<Message<string, byte[]>>

Inheritance

object ← CloudEventMapper

Implements

IKafkaEnvelopeMapper, IEnvelopeMapper<Message<string, byte[]>, Message<string, byte[]>>, IOutgoingMapper<Message<string, byte[]>>, IIncomingMapper<Message<string, byte[]>>

Inherited Members

object.GetType(), object.MemberwiseClone(), object.ToString(), object.Equals(object?), object.Equals(object?, object?), object.ReferenceEquals(object?, object?), object.GetHashCode()

Constructors

CloudEventMapper(IOptions<ServiceBusOptions>)

public CloudEventMapper(IOptions<ServiceBusOptions> serviceBusOptions)

Parameters

serviceBusOptions IOptions<ServiceBusOptions>

Methods

MapEnvelopeToOutgoing(Envelope, Message<string, byte[]>)

public void MapEnvelopeToOutgoing(Envelope envelope, Message<string, byte[]> outgoing)

Parameters

envelope Envelope

outgoing Message<string, byte[]>

MapIncomingToEnvelope(Envelope, Message<string, byte[]>)

public void MapIncomingToEnvelope(Envelope envelope, Message<string, byte[]> incoming)

Parameters

envelope Envelope

incoming Message<string, byte[]>