Class CloudEventsAmqpMapper

Namespace

Ratatoskr.RabbitMq

Assembly

Ratatoskr.RabbitMq.dll

Default implementation of IRabbitMqEnvelopeMapper that follows the CloudEvents AMQP protocol binding. See: https://github.com/cloudevents/spec/blob/main/cloudevents/bindings/amqp-protocol-binding.md

public class CloudEventsAmqpMapper : IRabbitMqEnvelopeMapper

Inheritance

object

CloudEventsAmqpMapper

Implements

IRabbitMqEnvelopeMapper

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

CloudEventsAmqpMapper(CloudEventsOptions, ILogger<CloudEventsAmqpMapper>)

Default implementation of IRabbitMqEnvelopeMapper that follows the CloudEvents AMQP protocol binding. See: https://github.com/cloudevents/spec/blob/main/cloudevents/bindings/amqp-protocol-binding.md

Methods

MapIncoming(BasicDeliverEventArgs)

Maps incoming RabbitMQ message to MessageProperties. Returns the body to deserialize (extracted from envelope for structured mode).

MapOutgoing(byte[], MessageProperties, BasicProperties)

Maps outgoing message to RabbitMQ properties. Returns the body to send (might be wrapped for structured mode).