17.81. Class QueueStorage
Namespace: ArmoniK.Core.Adapters.RabbitMQ
Assembly: ArmoniK.Core.Adapters.RabbitMQ.dll
public class QueueStorage : QueueStorageBase, IQueueStorage, IInitializable, IHealthCheckProvider
17.81.1. Inheritance
17.81.2. Derived
17.81.3. Implements
17.81.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()
17.81.5. Constructors
17.81.5.1. QueueStorage(Amqp, IConnectionRabbit)
protected QueueStorage(Amqp options, IConnectionRabbit connectionRabbit)
17.81.5.1.1. Parameters
options Amqp
connectionRabbit IConnectionRabbit
17.81.6. Fields
17.81.6.1. ConnectionRabbit
protected readonly IConnectionRabbit ConnectionRabbit
17.81.6.1.1. Field Value
17.81.7. Methods
17.81.7.1. Init(CancellationToken)
Executes an initialization process for the class
public override Task Init(CancellationToken cancellationToken)
17.81.7.1.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
17.81.7.1.2. Returns
Task representing the asynchronous execution of the method