26.8. Class PushQueueStorage
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class PushQueueStorage : QueueStorage, IPushQueueStorage, IQueueStorage, IInitializable, IHealthCheckProvider
26.8.1. Inheritance
object ← QueueStorageBase ← QueueStorage ← PushQueueStorage
26.8.2. Implements
IPushQueueStorage, IQueueStorage, IInitializable, IHealthCheckProvider
26.8.3. Inherited Members
QueueStorage.ConnectionAmqp, QueueStorage.NbLinks, QueueStorage.Init(CancellationToken), QueueStorageBase.Options, QueueStorageBase.IsInitialized, QueueStorageBase.Init(CancellationToken), QueueStorageBase.Check(HealthCheckTag), QueueStorageBase.MaxPriority, object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
26.8.4. Constructors
26.8.4.1. PushQueueStorage(Amqp, IConnectionAmqp, ILogger<PushQueueStorage>)
public PushQueueStorage(Amqp options, IConnectionAmqp connectionAmqp, ILogger<PushQueueStorage> logger)
26.8.4.1.1. Parameters
options Amqp
connectionAmqp IConnectionAmqp
logger ILogger<PushQueueStorage>
26.8.5. Methods
26.8.5.1. PushMessagesAsync(IEnumerable<MessageData>, string, CancellationToken)
Puts messages into the queue, handles priorities of messages
public Task PushMessagesAsync(IEnumerable<MessageData> messages, string partitionId, CancellationToken cancellationToken = default)
26.8.5.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.8.5.1.2. Returns
Task representing the asynchronous execution of the method