22.74. Class QueueStorageBase
Namespace: ArmoniK.Core.Adapters.QueueCommon
Assembly: ArmoniK.Core.Adapters.QueueCommon.dll
Represents the base class for queue storage implementations
public class QueueStorageBase : IQueueStorage, IInitializable, IHealthCheckProvider
22.74.1. Inheritance
22.74.2. Derived
22.74.3. Implements
22.74.4. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
22.74.5. Constructors
22.74.5.1. QueueStorageBase(Amqp)
Initializes a new instance of the
protected QueueStorageBase(Amqp options)
22.74.5.1.1. Parameters
options Amqp
The AMQP options to configure the queue storage.
22.74.5.1.2. Exceptions
Thrown when any of the required options are not defined or invalid.
22.74.6. Fields
22.74.6.1. IsInitialized
Gets a value indicating whether the queue storage has been initialized.
public bool IsInitialized
22.74.6.1.1. Field Value
22.74.6.2. Options
Represents the configuration settings for the AMQP (Advanced Message Queuing Protocol) connection.
public readonly Amqp Options
22.74.6.2.1. Field Value
22.74.7. Properties
22.74.7.1. MaxPriority
Max priority supported by the queue
public int MaxPriority { get; }
22.74.7.1.1. Property Value
22.74.8. Methods
22.74.8.1. Check(HealthCheckTag)
Checks the status of a class for the given health check type.
public virtual Task<HealthCheckResult> Check(HealthCheckTag tag)
22.74.8.1.1. Parameters
tag HealthCheckTag
Health check for which the class has to answer.
22.74.8.1.2. Returns
The result of the check containing the status of the class for the health check type.
22.74.8.2. Init(CancellationToken)
Executes an initialization process for the class
public virtual Task Init(CancellationToken cancellationToken)
22.74.8.2.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.74.8.2.2. Returns
Task representing the asynchronous execution of the method