21.15. Class QueueStorage
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider
21.15.1. Inheritance
21.15.2. Derived
21.15.3. Implements
21.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()
21.15.5. Constructors
21.15.5.1. QueueStorage(Amqp, IConnectionAmqp)
public QueueStorage(Amqp options, IConnectionAmqp connectionAmqp)
21.15.5.1.1. Parameters
options Amqp
connectionAmqp IConnectionAmqp
21.15.6. Fields
21.15.6.1. ConnectionAmqp
protected readonly IConnectionAmqp ConnectionAmqp
21.15.6.1.1. Field Value
21.15.6.2. NbLinks
protected readonly int NbLinks
21.15.6.2.1. Field Value
21.15.7. Methods
21.15.7.1. Init(CancellationToken)
Executes an initialization process for the class
public override Task Init(CancellationToken cancellationToken)
21.15.7.1.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
21.15.7.1.2. Returns
Task representing the asynchronous execution of the method