Class PostgreSqlOutboxWriter

Namespace

Silverback.Messaging.Producing.TransactionalOutbox

Assembly

Silverback.Storage.PostgreSql.dll

Writes to the PostgreSql outbox.

public class PostgreSqlOutboxWriter : IOutboxWriter

Inheritance

object

PostgreSqlOutboxWriter

Implements

IOutboxWriter

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

PostgreSqlOutboxWriter(PostgreSqlOutboxSettings)

Initializes a new instance of the PostgreSqlOutboxWriter class.

public PostgreSqlOutboxWriter(PostgreSqlOutboxSettings settings)

Parameters

settings PostgreSqlOutboxSettings

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