Class PostgreSqlOutboxWriter

Writes to the PostgreSql outbox.

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()

Namespace: Silverback.Messaging.Producing.TransactionalOutbox

Assembly: Silverback.Storage.PostgreSql.dll

Syntax

public class PostgreSqlOutboxWriter : IOutboxWriter

Constructors

PostgreSqlOutboxWriter(PostgreSqlOutboxSettings)

Initializes a new instance of the PostgreSqlOutboxWriter class.

Declaration

public PostgreSqlOutboxWriter(PostgreSqlOutboxSettings settings)

Parameters

Type	Name	Description
PostgreSqlOutboxSettings	settings	The outbox settings.

Methods

AddAsync(OutboxMessage, ISilverbackContext?, CancellationToken)

Writes to the PostgreSql outbox.

Declaration

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

Parameters

Type	Name	Description
OutboxMessage	outboxMessage
ISilverbackContext	context
CancellationToken	cancellationToken

Returns

Type	Description
Task

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

Writes to the PostgreSql outbox.

Declaration

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

Parameters

Type	Name	Description
IAsyncEnumerable<OutboxMessage>	outboxMessages
ISilverbackContext	context
CancellationToken	cancellationToken

Returns

Type	Description
Task

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

Writes to the PostgreSql outbox.

Declaration

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

Parameters

Type	Name	Description
IEnumerable<OutboxMessage>	outboxMessages
ISilverbackContext	context
CancellationToken	cancellationToken

Returns

Type	Description
Task

Implements

IOutboxWriter