17.78. Class PushQueueStorage
Namespace: ArmoniK.Core.Adapters.RabbitMQ
Assembly: ArmoniK.Core.Adapters.RabbitMQ.dll
public class PushQueueStorage : QueueStorage, IPushQueueStorage, IQueueStorage, IInitializable, IHealthCheckProvider
17.78.1. Inheritance
17.78.2. Implements
IPushQueueStorage, IQueueStorage, IInitializable, IHealthCheckProvider
17.78.3. Inherited Members
QueueStorage.ConnectionRabbit, 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()
17.78.4. Constructors
17.78.4.1. PushQueueStorage(Amqp, IConnectionRabbit, ILogger<PushQueueStorage>)
public PushQueueStorage(Amqp options, IConnectionRabbit connectionRabbit, ILogger<PushQueueStorage> logger)
17.78.4.1.1. Parameters
options Amqp
connectionRabbit IConnectionRabbit
logger ILogger<PushQueueStorage>
17.78.5. Methods
17.78.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)
17.78.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
17.78.5.1.2. Returns
Task representing the asynchronous execution of the method