Class InMemoryOutbox

An outbound queue persisted in memory. Note that writing in the queue is thread-safe but reading is not. Implements both IOutboxWriter and IOutboxReader.

Inheritance
System.Object
TransactionalList<OutboxStoredMessage>
InMemoryOutbox
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 InMemoryOutbox : TransactionalList<OutboxStoredMessage>, IOutboxWriter, IOutboxReader

Constructors

| Improve this doc View source

InMemoryOutbox(TransactionalListSharedItems<OutboxStoredMessage>)

Initializes a new instance of the InMemoryOutbox class.

Declaration
public InMemoryOutbox(TransactionalListSharedItems<OutboxStoredMessage> sharedItems)
Parameters
Type Name Description
TransactionalListSharedItems<OutboxStoredMessage> sharedItems

The messages shared between the instances of this repository.

Methods

| Improve this doc View source

AcknowledgeAsync(OutboxStoredMessage)

Declaration
public Task AcknowledgeAsync(OutboxStoredMessage outboxMessage)
Parameters
Type Name Description
OutboxStoredMessage outboxMessage
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

AcknowledgeAsync(IEnumerable<OutboxStoredMessage>)

Declaration
public Task AcknowledgeAsync(IEnumerable<OutboxStoredMessage> outboxMessages)
Parameters
Type Name Description
System.Collections.Generic.IEnumerable<OutboxStoredMessage> outboxMessages
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

GetLengthAsync()

Declaration
public Task<int> GetLengthAsync()
Returns
Type Description
System.Threading.Tasks.Task<System.Int32>
| Improve this doc View source

GetMaxAgeAsync()

Declaration
public Task<TimeSpan> GetMaxAgeAsync()
Returns
Type Description
System.Threading.Tasks.Task<System.TimeSpan>
| Improve this doc View source

ReadAsync(Int32)

Declaration
public Task<IReadOnlyCollection<OutboxStoredMessage>> ReadAsync(int count)
Parameters
Type Name Description
System.Int32 count
Returns
Type Description
System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyCollection<OutboxStoredMessage>>
| Improve this doc View source

RetryAsync(OutboxStoredMessage)

Declaration
public Task RetryAsync(OutboxStoredMessage outboxMessage)
Parameters
Type Name Description
OutboxStoredMessage outboxMessage
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

RetryAsync(IEnumerable<OutboxStoredMessage>)

Declaration
public Task RetryAsync(IEnumerable<OutboxStoredMessage> outboxMessages)
Parameters
Type Name Description
System.Collections.Generic.IEnumerable<OutboxStoredMessage> outboxMessages
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