Interface IRawInboundEnvelope

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

Inherited Members

IRawBrokerEnvelope.Headers

IRawBrokerEnvelope.RawMessage

Namespace: Silverback.Messaging.Messages

Assembly: Silverback.Integration.dll

Syntax

public interface IRawInboundEnvelope : IRawBrokerEnvelope

Properties

BrokerMessageIdentifier

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

Declaration

IBrokerMessageIdentifier BrokerMessageIdentifier { get; }

Property Value

Type	Description
IBrokerMessageIdentifier

Consumer

Gets the IConsumer that consumed this message.

Declaration

IConsumer Consumer { get; }

Property Value

Type	Description
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).

Declaration

ConsumerEndpoint Endpoint { get; }

Property Value

Type	Description
ConsumerEndpoint

Methods

CloneReplacingRawMessage(Stream?)

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

Declaration

IRawInboundEnvelope CloneReplacingRawMessage(Stream? newRawMessage)

Parameters

Type	Name	Description
Stream	newRawMessage	The new raw message to be set.

Returns

Type	Description
IRawInboundEnvelope	The new envelope.