17.73. Class QueueStorageBase

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

public class QueueStorageBase : IQueueStorage, IInitializable, IHealthCheckProvider

17.73.1. Inheritance

objectQueueStorageBase

17.73.2. Derived

QueueStorage, QueueStorage

17.73.3. Implements

IQueueStorage, IInitializable, IHealthCheckProvider

17.73.4. Inherited Members

object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()

17.73.5. Constructors

17.73.5.1. QueueStorageBase(Amqp)

protected QueueStorageBase(Amqp options)

17.73.5.1.1. Parameters

options Amqp

17.73.6. Fields

17.73.6.1. IsInitialized

public bool IsInitialized

17.73.6.1.1. Field Value

bool

17.73.6.2. Options

public readonly Amqp Options

17.73.6.2.1. Field Value

Amqp

17.73.7. Properties

17.73.7.1. MaxPriority

Max priority supported by the queue

public int MaxPriority { get; }

17.73.7.1.1. Property Value

int

17.73.8. Methods

17.73.8.1. Check(HealthCheckTag)

Checks the status of a class for the given health check type.

public virtual Task<HealthCheckResult> Check(HealthCheckTag tag)

17.73.8.1.1. Parameters

tag HealthCheckTag

Health check for which the class has to answer.

17.73.8.1.2. Returns

Task<HealthCheckResult>

The result of the check containing the status of the class for the health check type.

17.73.8.2. Init(CancellationToken)

Executes an initialization process for the class

public virtual Task Init(CancellationToken cancellationToken)

17.73.8.2.1. Parameters

cancellationToken CancellationToken

Token used to cancel the execution of the method

17.73.8.2.2. Returns

Task

Task representing the asynchronous execution of the method