23.11. Class QueueStorage
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider
23.11.1. Inheritance
object ← QueueStorageBase ← QueueStorage
23.11.2. Derived
23.11.3. Implements
IQueueStorage, IInitializable, IHealthCheckProvider
23.11.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()
23.11.5. Constructors
23.11.5.1. QueueStorage(Amqp, IConnectionAmqp)
public QueueStorage(Amqp options, IConnectionAmqp connectionAmqp)
23.11.5.1.1. Parameters
options Amqp
connectionAmqp IConnectionAmqp
23.11.6. Fields
23.11.6.1. ConnectionAmqp
protected readonly IConnectionAmqp ConnectionAmqp
23.11.6.1.1. Field Value
23.11.6.2. NbLinks
protected readonly int NbLinks
23.11.6.2.1. Field Value
23.11.7. Methods
23.11.7.1. Init(CancellationToken)
Executes an initialization process for the class
public override Task Init(CancellationToken cancellationToken)
23.11.7.1.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
23.11.7.1.2. Returns
Task representing the asynchronous execution of the method