17.15. Class QueueStorage
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider
17.15.1. Inheritance
17.15.2. Derived
17.15.3. Implements
17.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()
17.15.5. Constructors
17.15.5.1. QueueStorage(Amqp, IConnectionAmqp)
public QueueStorage(Amqp options, IConnectionAmqp connectionAmqp)
17.15.5.1.1. Parameters
options Amqp
connectionAmqp IConnectionAmqp
17.15.6. Fields
17.15.6.1. ConnectionAmqp
protected readonly IConnectionAmqp ConnectionAmqp
17.15.6.1.1. Field Value
17.15.6.2. NbLinks
protected readonly int NbLinks
17.15.6.2.1. Field Value
17.15.7. Methods
17.15.7.1. Init(CancellationToken)
Executes an initialization process for the class
public override Task Init(CancellationToken cancellationToken)
17.15.7.1.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
17.15.7.1.2. Returns
Task representing the asynchronous execution of the method