Class MessageExtensions

Inheritance
object
MessageExtensions
Inherited Members
Namespace: Volo.Abp.EventBus.Kafka
Assembly: Volo.Abp.EventBus.Kafka.dll
Syntax
public static class MessageExtensions

Methods

GetCorrelationId<TKey, TValue>(Message<TKey, TValue>)

Declaration
public static string? GetCorrelationId<TKey, TValue>(this Message<TKey, TValue> message)
Parameters
Type Name Description
Message<TKey, TValue> message
Returns
Type Description
string
Type Parameters
Name Description
TKey
TValue

GetMessageId<TKey, TValue>(Message<TKey, TValue>)

Declaration
public static string? GetMessageId<TKey, TValue>(this Message<TKey, TValue> message)
Parameters
Type Name Description
Message<TKey, TValue> message
Returns
Type Description
string
Type Parameters
Name Description
TKey
TValue