Class InMemoryOutboxWriter

Namespace

Silverback.Messaging.Producing.TransactionalOutbox

Assembly

Silverback.Storage.Memory.dll

Writes to the in-memory outbox.

public class InMemoryOutboxWriter : IOutboxWriter

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

Constructors

InMemoryOutboxWriter(InMemoryOutbox, ISilverbackLogger<InMemoryOutboxWriter>)

Initializes a new instance of the InMemoryOutboxWriter class.

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

Parameters

outbox InMemoryOutbox

The in-memory outbox shared between the InMemoryOutboxWriter and InMemoryOutboxReader.

logger ISilverbackLogger<InMemoryOutboxWriter>

The logger.

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