26.10. Class QueueMessageHandler
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class QueueMessageHandler : IQueueMessageHandler, IAsyncDisposable
26.10.1. Inheritance
26.10.2. Implements
IQueueMessageHandler, IAsyncDisposable
26.10.3. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
26.10.4. Constructors
26.10.4.1. QueueMessageHandler(Message, ISenderLink, IReceiverLink, string, ILogger, CancellationToken)
public QueueMessageHandler(Message message, ISenderLink sender, IReceiverLink receiver, string taskId, ILogger logger, CancellationToken cancellationToken)
26.10.4.1.1. Parameters
message Message
sender ISenderLink
receiver IReceiverLink
taskId string
logger ILogger
cancellationToken CancellationToken
26.10.5. Properties
26.10.5.1. CancellationToken
Used to signal that the message ownership has been lost
public CancellationToken CancellationToken { get; set; }
26.10.5.1.1. Property Value
26.10.5.2. MessageId
Id of the message
public string MessageId { get; }
26.10.5.2.1. Property Value
26.10.5.3. ReceptionDateTime
Date of reception of the message
public DateTime ReceptionDateTime { get; init; }
26.10.5.3.1. Property Value
26.10.5.4. Status
Status of the message. Used when the handler is disposed to notify the queue.
public QueueMessageStatus Status { get; set; }
26.10.5.4.1. Property Value
QueueMessageStatus
26.10.5.5. TaskId
Task Id contained in the message
public string TaskId { get; }
26.10.5.5.1. Property Value
26.10.6. Methods
26.10.6.1. DisposeAsync()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.
public ValueTask DisposeAsync()
26.10.6.1.1. Returns
A task that represents the asynchronous dispose operation.
26.10.6.2. ~QueueMessageHandler()
protected ~QueueMessageHandler()