Interface IInboundLog
Used by the LogExactlyOnceStrategy to keep track of each processed message and guarantee that each one is processed only once.
Namespace: Silverback.Messaging.Inbound.ExactlyOnce.Repositories
Assembly: Silverback.Integration.dll
Syntax
public interface IInboundLog : ITransactionalMethods
| Improve this doc View sourceAddAsync(IRawInboundEnvelope)
Add the message contained in the specified envelope to the log.
Declaration
Task AddAsync(IRawInboundEnvelope envelope)Parameters
| Type | Name | Description |
|---|---|---|
| IRawInboundEnvelope | envelope | The envelope containing the message to be added. |
Returns
| Type | Description |
|---|---|
| Task | A Task representing the asynchronous operation. |
ExistsAsync(IRawInboundEnvelope)
Returns a boolean value indicating whether this very same message has already been logged for the same consumer group.
Declaration
Task<bool> ExistsAsync(IRawInboundEnvelope envelope)Parameters
| Type | Name | Description |
|---|---|---|
| IRawInboundEnvelope | envelope | The envelope containing the message to be checked. |
Returns
| Type | Description |
|---|---|
| Task<bool> | A Task<TResult> representing the asynchronous operation. The task result contains a value indicating whether the message was found in the log. |
GetLengthAsync()
Returns the total number of messages in the log.
Declaration
Task<int> GetLengthAsync()Returns
| Type | Description |
|---|---|
| Task<int> | A Task<TResult> representing the result of the asynchronous operation. The task result contains the log length. |