22.15. Class QueueStorage
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider
22.15.1. Inheritance
22.15.2. Derived
22.15.3. Implements
22.15.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()
22.15.5. Constructors
22.15.5.1. QueueStorage(Amqp, IConnectionAmqp)
public QueueStorage(Amqp options, IConnectionAmqp connectionAmqp)
22.15.5.1.1. Parameters
options Amqp
connectionAmqp IConnectionAmqp
22.15.6. Fields
22.15.6.1. ConnectionAmqp
protected readonly IConnectionAmqp ConnectionAmqp
22.15.6.1.1. Field Value
22.15.6.2. NbLinks
protected readonly int NbLinks
22.15.6.2.1. Field Value
22.15.7. Methods
22.15.7.1. Init(CancellationToken)
Executes an initialization process for the class
public override Task Init(CancellationToken cancellationToken)
22.15.7.1.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.15.7.1.2. Returns
Task representing the asynchronous execution of the method