22.9. Class ConnectionAmqp

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

[UsedImplicitly]
public class ConnectionAmqp : IConnectionAmqp, IInitializable, IHealthCheckProvider

22.9.1. Inheritance

objectConnectionAmqp

22.9.2. Implements

IConnectionAmqp, IInitializable, IHealthCheckProvider

22.9.3. Inherited Members

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

22.9.4. Constructors

22.9.4.1. ConnectionAmqp(Amqp, ILogger<ConnectionAmqp>)

public ConnectionAmqp(Amqp options, ILogger<ConnectionAmqp> logger)

22.9.4.1.1. Parameters

options Amqp

logger ILogger<ConnectionAmqp>

22.9.5. Methods

22.9.5.1. Check(HealthCheckTag)

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

public Task<HealthCheckResult> Check(HealthCheckTag tag)

22.9.5.1.1. Parameters

tag HealthCheckTag

Health check for which the class has to answer.

22.9.5.1.2. Returns

Task<HealthCheckResult>

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

22.9.5.2. GetConnectionAsync(CancellationToken)

public Task<Connection> GetConnectionAsync(CancellationToken cancellationToken = default)

22.9.5.2.1. Parameters

cancellationToken CancellationToken

22.9.5.2.2. Returns

Task<Connection>

22.9.5.3. Init(CancellationToken)

Executes an initialization process for the class

public Task Init(CancellationToken cancellationToken = default)

22.9.5.3.1. Parameters

cancellationToken CancellationToken

Token used to cancel the execution of the method

22.9.5.3.2. Returns

Task

Task representing the asynchronous execution of the method