Class DbOutboxWriter

Stores the outbound messages into the database. Used by the OutboxProduceStrategy.

Inheritance
System.Object
RepositoryBase<OutboxMessage>
DbOutboxWriter
Implements
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Outbound.TransactionalOutbox.Repositories
Assembly: Silverback.Integration.dll
Syntax
public class DbOutboxWriter : RepositoryBase<OutboxMessage>, IOutboxWriter

Constructors

| Improve this doc View source

DbOutboxWriter(IDbContext)

Initializes a new instance of the DbOutboxWriter class.

Declaration
public DbOutboxWriter(IDbContext dbContext)
Parameters
Type Name Description
IDbContext dbContext

The IDbContext to use as storage.

Methods

| Improve this doc View source

CommitAsync()

Declaration
public Task CommitAsync()
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

RollbackAsync()

Declaration
public Task RollbackAsync()
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

WriteAsync(Object, Byte[], IReadOnlyCollection<MessageHeader>, String, String)

Declaration
public Task WriteAsync(object message, byte[] messageBytes, IReadOnlyCollection<MessageHeader> headers, string endpointName, string actualEndpointName)
Parameters
Type Name Description
System.Object message
System.Byte[] messageBytes
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String endpointName
System.String actualEndpointName
Returns
Type Description
System.Threading.Tasks.Task

Implements