21.111. 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.111.1. Implements
21.111.2. Methods
21.111.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.111.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.111.2.1.2. Returns
Task representing the asynchronous execution of the method