Momentum .NET

Appearance

Class CloudEventMapper ​

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

csharp
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>) ​

csharp
public CloudEventMapper(IOptions<ServiceBusOptions> serviceBusOptions)

Parameters ​

serviceBusOptions IOptions<ServiceBusOptions>

Methods ​

AllHeaders() ​

csharp
public IEnumerable<string> AllHeaders()

Returns ​

IEnumerable<string>

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

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

Parameters ​

envelope Envelope

outgoing Message<string, byte[]>

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

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

Parameters ​

envelope Envelope

incoming Message<string, byte[]>

Momentum .NET