17.108. Interface IPullQueueStorage
Namespace: ArmoniK.Core.Base
Assembly: ArmoniK.Core.Base.dll
Interface to retrieve messages from the queue
public interface IPullQueueStorage : IQueueStorage, IInitializable, IHealthCheckProvider
17.108.1. Implements
17.108.2. Methods
17.108.2.1. PullMessagesAsync(int, CancellationToken)
Gets messages from the queue
IAsyncEnumerable<IQueueMessageHandler> PullMessagesAsync(int nbMessages, CancellationToken cancellationToken = default)
17.108.2.1.1. Parameters
nbMessages int
Number of messages to retrieve
cancellationToken CancellationToken
Token used to cancel the execution of the method
17.108.2.1.2. Returns
IAsyncEnumerable<IQueueMessageHandler>
Enumerator allowing async iteration over the message queue