26.11. Class QueueStorage

Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll

public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider

26.11.1. Inheritance

object ← QueueStorageBase ← QueueStorage

IQueueStorage, IInitializable, IHealthCheckProvider

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()

public QueueStorage(Amqp options, IConnectionAmqp connectionAmqp)

options Amqp

connectionAmqp IConnectionAmqp

protected readonly IConnectionAmqp ConnectionAmqp

protected readonly int NbLinks

Executes an initialization process for the class

public override Task Init(CancellationToken cancellationToken)

cancellationToken CancellationToken

Token used to cancel the execution of the method

Task representing the asynchronous execution of the method