21.82. Class QueueStorage
Namespace: ArmoniK.Core.Adapters.RabbitMQ
Assembly: ArmoniK.Core.Adapters.RabbitMQ.dll
public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider
21.82.1. Inheritance
21.82.2. Derived
21.82.3. Implements
21.82.4. Inherited Members
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()
21.82.5. Constructors
21.82.5.1. QueueStorage(Amqp, IConnectionRabbit)
protected QueueStorage(Amqp options, IConnectionRabbit connectionRabbit)
21.82.5.1.1. Parameters
options Amqp
connectionRabbit IConnectionRabbit
21.82.6. Fields
21.82.6.1. ConnectionRabbit
protected readonly IConnectionRabbit ConnectionRabbit
21.82.6.1.1. Field Value
21.82.7. Methods
21.82.7.1. Init(CancellationToken)
Executes an initialization process for the class
public override Task Init(CancellationToken cancellationToken)
21.82.7.1.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
21.82.7.1.2. Returns
Task representing the asynchronous execution of the method