21.109. Interface IPushQueueStorage
Namespace: ArmoniK.Core.Base
Assembly: ArmoniK.Core.Base.dll
Interface to insert messages into the queue
public interface IPushQueueStorage : IQueueStorage, IInitializable, IHealthCheckProvider
21.109.1. Implements
21.109.2. Methods
21.109.2.1. PushMessagesAsync(IEnumerable<MessageData>, string, CancellationToken)
Puts messages into the queue, handles priorities of messages
Task PushMessagesAsync(IEnumerable<MessageData> messages, string partitionId, CancellationToken cancellationToken = default)
21.109.2.1.1. Parameters
messages IEnumerable<MessageData>
Collection of messages
partitionId string
Id of the partition
cancellationToken CancellationToken
Token used to cancel the execution of the method
21.109.2.1.2. Returns
Task representing the asynchronous execution of the method