Class InboundEnvelopeBuilderExtensions

Namespace

Silverback.Messaging.Messages

Assembly

Silverback.Integration.Kafka.Testing.dll

Adds the Kafka specific methods to the InboundEnvelopeBuilder<TMessage>.

public static class InboundEnvelopeBuilderExtensions

Inheritance

object

InboundEnvelopeBuilderExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

WithKafkaKey<TMessage>(InboundEnvelopeBuilder<TMessage>, string)

Sets the key of the message consumed from Kafka.

public static InboundEnvelopeBuilder<TMessage> WithKafkaKey<TMessage>(this InboundEnvelopeBuilder<TMessage> builder, string key) where TMessage : class

Parameters

builder InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage>.

key string

The Kafka message key.

Returns

InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage> so that additional calls can be chained.

Type Parameters

TMessage

The type of the message.

WithKafkaOffset<TMessage>(InboundEnvelopeBuilder<TMessage>, KafkaOffset)

Sets the offset of the message.

public static InboundEnvelopeBuilder<TMessage> WithKafkaOffset<TMessage>(this InboundEnvelopeBuilder<TMessage> builder, KafkaOffset offset) where TMessage : class

Parameters

builder InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage>.

offset KafkaOffset

The offset.

Returns

InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage> so that additional calls can be chained.

Type Parameters

TMessage

The type of the message.

WithKafkaOffset<TMessage>(InboundEnvelopeBuilder<TMessage>, string, int, long)

Sets the offset of the message.

public static InboundEnvelopeBuilder<TMessage> WithKafkaOffset<TMessage>(this InboundEnvelopeBuilder<TMessage> builder, string topic, int partition, long offset) where TMessage : class

Parameters

builder InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage>.

topic string

The topic.

partition int

The partition.

offset long

The offset.

Returns

InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage> so that additional calls can be chained.

Type Parameters

TMessage

The type of the message.

WithKafkaTimestamp<TMessage>(InboundEnvelopeBuilder<TMessage>, DateTime)

Sets the timestamp of the message consumed from Kafka.

public static InboundEnvelopeBuilder<TMessage> WithKafkaTimestamp<TMessage>(this InboundEnvelopeBuilder<TMessage> builder, DateTime timestamp) where TMessage : class

Parameters

builder InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage>.

timestamp DateTime

The timestamp of the message.

Returns

InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage> so that additional calls can be chained.

Type Parameters

TMessage

The type of the message.

WithKafkaTopic<TMessage>(InboundEnvelopeBuilder<TMessage>, string, int)

Sets the topic and, optionally, the partition from which the message was consumed.

public static InboundEnvelopeBuilder<TMessage> WithKafkaTopic<TMessage>(this InboundEnvelopeBuilder<TMessage> builder, string topic, int partition = 0) where TMessage : class

Parameters

builder InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage>.

topic string

The topic.

partition int

The partition index. Set to 0 if not specified.

Returns

InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage> so that additional calls can be chained.

Type Parameters

TMessage

The type of the message.

WithMqttCorrelationData<TMessage>(InboundEnvelopeBuilder<TMessage>, byte[])

Sets the correlation data.

public static InboundEnvelopeBuilder<TMessage> WithMqttCorrelationData<TMessage>(this InboundEnvelopeBuilder<TMessage> builder, byte[] correlationData) where TMessage : class

Parameters

builder InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage>.

correlationData byte[]

The correlation data.

Returns

InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage> so that additional calls can be chained.

Type Parameters

TMessage

The type of the message.

WithMqttTopic<TMessage>(InboundEnvelopeBuilder<TMessage>, string)

Sets the topic from which the message was consumed.

public static InboundEnvelopeBuilder<TMessage> WithMqttTopic<TMessage>(this InboundEnvelopeBuilder<TMessage> builder, string topic) where TMessage : class

Parameters

builder InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage>.

topic string

The topic name.

Returns

InboundEnvelopeBuilder<TMessage>

The InboundEnvelopeBuilder<TMessage> so that additional calls can be chained.

Type Parameters

TMessage

The type of the message.