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