Class SilverbackContextKafkaTransactionExtensions

Namespace

Silverback.Messaging.Transactions

Assembly

Silverback.Integration.Kafka.dll

Adds the InitKafkaTransaction(ISilverbackContext, string?) method to the Silverback.SilverbackContext.

public static class SilverbackContextKafkaTransactionExtensions

Inheritance

object

SilverbackContextKafkaTransactionExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

InitKafkaTransaction(ISilverbackContext, string?)

Initializes the Kafka transaction.

public static IKafkaTransaction InitKafkaTransaction(this ISilverbackContext context, string? transactionalIdSuffix = null)

Parameters

context ISilverbackContext

The ISilverbackContext.

transactionalIdSuffix string

The optional suffix to be appended to the transactional Id. This must be used to allow multiple concurrent transactions.

Returns

IKafkaTransaction

The created IKafkaTransaction.