Class SqliteOutboxWriter

Namespace

Silverback.Messaging.Producing.TransactionalOutbox

Assembly

Silverback.Storage.Sqlite.dll

Writes to the SQLite outbox.

public class SqliteOutboxWriter : IOutboxWriter

Inheritance

object

SqliteOutboxWriter

Implements

IOutboxWriter

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

SqliteOutboxWriter(SqliteOutboxSettings)

Initializes a new instance of the SqliteOutboxWriter class.

public SqliteOutboxWriter(SqliteOutboxSettings settings)

Parameters

settings SqliteOutboxSettings

The outbox settings.

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