Interface IExactlyOnceStrategyImplementation
The strategy used to guarantee that each message is consumed only once.
Namespace: Silverback.Messaging.Inbound.ExactlyOnce
Assembly: Silverback.Integration.dll
Syntax
public interface IExactlyOnceStrategyImplementationMethods
| Improve this doc View sourceCheckIsAlreadyProcessedAsync(ConsumerPipelineContext)
Checks whether the message contained in the specified envelope was already processed and must therefore be skipped.
If the message is new, this method implicitly writes its reference to the store and enlists it into the consumer transaction.
Declaration
Task<bool> CheckIsAlreadyProcessedAsync(ConsumerPipelineContext context)Parameters
| Type | Name | Description |
|---|---|---|
| ConsumerPipelineContext | context | The context that is passed along the consumer behaviors pipeline. |
Returns
| Type | Description |
|---|---|
| Task<bool> | A Task<TResult> representing the asynchronous operation. The task result contains a value indicating whether the message was already processed. |