30.106. Interface IPushQueueStorage
Namespace: ArmoniK.Core.Base
Assembly: ArmoniK.Core.Base.dll
Interface to insert messages into the queue
public interface IPushQueueStorage : IQueueStorage, IInitializable, IHealthCheckProvider
30.106.1. Implements
30.106.2. Methods
30.106.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)
30.106.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
30.106.2.1.2. Returns
Task representing the asynchronous execution of the method