Interface IRawInboundEnvelope

Namespace

Silverback.Messaging.Messages

Assembly

Silverback.Integration.dll

Wraps the message that is being consumed from an inbound endpoint.

public interface IRawInboundEnvelope : IRawBrokerEnvelope

Inherited Members

IRawBrokerEnvelope.Headers

IRawBrokerEnvelope.RawMessage

Properties

BrokerMessageIdentifier

Gets the message identifier on the message broker (the Kafka offset or similar).

IBrokerMessageIdentifier BrokerMessageIdentifier { get; }

Property Value

IBrokerMessageIdentifier

Consumer

Gets the IConsumer that consumed this message.

IConsumer Consumer { get; }

Property Value

IConsumer

Endpoint

Gets the source endpoint. It is mostly relevant when the EndpointConfiguration points to multiple endpoints (for example if consuming multiple topics with a single consumer).

ConsumerEndpoint Endpoint { get; }

Property Value

ConsumerEndpoint

Methods

CloneReplacingRawMessage(Stream?)

Clones the envelope and replaces the raw message with the specified one.

IRawInboundEnvelope CloneReplacingRawMessage(Stream? newRawMessage)

Parameters

newRawMessage Stream

The new raw message to be set.

Returns

IRawInboundEnvelope

The new envelope.