21.80. Class QueueMessageHandler

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

public class QueueMessageHandler : IQueueMessageHandler, IAsyncDisposable

21.80.1. Inheritance

objectQueueMessageHandler

21.80.2. Implements

IQueueMessageHandler, IAsyncDisposable

21.80.3. Inherited Members

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

21.80.4. Constructors

21.80.4.1. QueueMessageHandler(IConnectionRabbit, BasicGetResult, string, ILogger, CancellationToken)

public QueueMessageHandler(IConnectionRabbit channel, BasicGetResult basicGetResult, string taskId, ILogger logger, CancellationToken cancellationToken)

21.80.4.1.1. Parameters

channel IConnectionRabbit

basicGetResult BasicGetResult

taskId string

logger ILogger

cancellationToken CancellationToken

21.80.5. Properties

21.80.5.1. CancellationToken

Used to signal that the message ownership has been lost

public CancellationToken CancellationToken { get; set; }

21.80.5.1.1. Property Value

CancellationToken

21.80.5.2. MessageId

Id of the message

public string MessageId { get; }

21.80.5.2.1. Property Value

string

21.80.5.3. ReceptionDateTime

Date of reception of the message

public DateTime ReceptionDateTime { get; init; }

21.80.5.3.1. Property Value

DateTime

21.80.5.4. Status

Status of the message. Used when the handler is disposed to notify the queue.

public QueueMessageStatus Status { get; set; }

21.80.5.4.1. Property Value

QueueMessageStatus

21.80.5.5. TaskId

Task Id contained in the message

public string TaskId { get; }

21.80.5.5.1. Property Value

string

21.80.6. Methods

21.80.6.1. DisposeAsync()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.

public ValueTask DisposeAsync()

21.80.6.1.1. Returns

ValueTask

A task that represents the asynchronous dispose operation.

21.80.6.2. ~QueueMessageHandler()

protected ~QueueMessageHandler()