30.11. Class QueueStorage
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider
30.11.1. Inheritance
object ← QueueStorageBase ← QueueStorage
30.11.2. Derived
30.11.3. Implements
IQueueStorage, IInitializable, IHealthCheckProvider
30.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()
30.11.5. Constructors
30.11.5.1. QueueStorage(Amqp, IConnectionAmqp)
public QueueStorage(Amqp options, IConnectionAmqp connectionAmqp)
30.11.5.1.1. Parameters
options Amqp
connectionAmqp IConnectionAmqp
30.11.6. Fields
30.11.6.1. ConnectionAmqp
protected readonly IConnectionAmqp ConnectionAmqp
30.11.6.1.1. Field Value
30.11.6.2. NbLinks
protected readonly int NbLinks
30.11.6.2.1. Field Value
30.11.7. Methods
30.11.7.1. Init(CancellationToken)
Executes an initialization process for the class
public override Task Init(CancellationToken cancellationToken)
30.11.7.1.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
30.11.7.1.2. Returns
Task representing the asynchronous execution of the method