Class InMemoryOutboxWriter

Writes to the in-memory outbox.

Inheritance

object

InMemoryOutboxWriter

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.Memory.dll

Syntax

public class InMemoryOutboxWriter : IOutboxWriter

Constructors

InMemoryOutboxWriter(InMemoryOutbox, ISilverbackLogger<InMemoryOutboxWriter>)

Initializes a new instance of the InMemoryOutboxWriter class.

Declaration

public InMemoryOutboxWriter(InMemoryOutbox outbox, ISilverbackLogger<InMemoryOutboxWriter> logger)

Parameters

Type	Name	Description
InMemoryOutbox	outbox	The in-memory outbox shared between the InMemoryOutboxWriter and InMemoryOutboxReader.
ISilverbackLogger<InMemoryOutboxWriter>	logger	The logger.

Methods

AddAsync(OutboxMessage, ISilverbackContext?, CancellationToken)

Writes to the in-memory 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 in-memory 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 in-memory 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