Class EntityFrameworkOutboxWriter

Namespace

Silverback.Messaging.Producing.TransactionalOutbox

Assembly

Silverback.Storage.EntityFramework.dll

Writes to the EntityFramework outbox.

public class EntityFrameworkOutboxWriter : IOutboxWriter

Inheritance

object

EntityFrameworkOutboxWriter

Implements

IOutboxWriter

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

EntityFrameworkOutboxWriter(EntityFrameworkOutboxSettings, IServiceScopeFactory)

Initializes a new instance of the EntityFrameworkOutboxWriter class.

public EntityFrameworkOutboxWriter(EntityFrameworkOutboxSettings settings, IServiceScopeFactory serviceScopeFactory)

Parameters

settings EntityFrameworkOutboxSettings

The outbox settings.

serviceScopeFactory IServiceScopeFactory

The IServiceScopeFactory.

Methods

AddAsync(OutboxMessage, ISilverbackContext?, CancellationToken)

public Task AddAsync(OutboxMessage outboxMessage, ISilverbackContext? context = null, CancellationToken cancellationToken = default)

Parameters

outboxMessage OutboxMessage

context ISilverbackContext

cancellationToken CancellationToken

Returns

Task

AddAsync(IAsyncEnumerable<OutboxMessage>, ISilverbackContext?, CancellationToken)

public Task AddAsync(IAsyncEnumerable<OutboxMessage> outboxMessages, ISilverbackContext? context = null, CancellationToken cancellationToken = default)

Parameters

outboxMessages IAsyncEnumerable<OutboxMessage>

context ISilverbackContext

cancellationToken CancellationToken

Returns

Task

AddAsync(IEnumerable<OutboxMessage>, ISilverbackContext?, CancellationToken)

public Task AddAsync(IEnumerable<OutboxMessage> outboxMessages, ISilverbackContext? context = null, CancellationToken cancellationToken = default)

Parameters

outboxMessages IEnumerable<OutboxMessage>

context ISilverbackContext

cancellationToken CancellationToken

Returns

Task