30.10. Class QueueMessageHandler
Namespace: ArmoniK.Core.Adapters.Amqp
Assembly: ArmoniK.Core.Adapters.Amqp.dll
public class QueueMessageHandler : IQueueMessageHandler, IAsyncDisposable
30.10.1. Inheritance
30.10.2. Implements
IQueueMessageHandler, IAsyncDisposable
30.10.3. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
30.10.4. Constructors
30.10.4.1. QueueMessageHandler(Message, ISenderLink, IReceiverLink, string, ILogger, CancellationToken)
public QueueMessageHandler(Message message, ISenderLink sender, IReceiverLink receiver, string taskId, ILogger logger, CancellationToken cancellationToken)
30.10.4.1.1. Parameters
message Message
sender ISenderLink
receiver IReceiverLink
taskId string
logger ILogger
cancellationToken CancellationToken
30.10.5. Properties
30.10.5.1. CancellationToken
Used to signal that the message ownership has been lost
public CancellationToken CancellationToken { get; set; }
30.10.5.1.1. Property Value
30.10.5.2. MessageId
Id of the message
public string MessageId { get; }
30.10.5.2.1. Property Value
30.10.5.3. ReceptionDateTime
Date of reception of the message
public DateTime ReceptionDateTime { get; init; }
30.10.5.3.1. Property Value
30.10.5.4. Status
Status of the message. Used when the handler is disposed to notify the queue.
public QueueMessageStatus Status { get; set; }
30.10.5.4.1. Property Value
QueueMessageStatus
30.10.5.5. TaskId
Task Id contained in the message
public string TaskId { get; }
30.10.5.5.1. Property Value
30.10.6. Methods
30.10.6.1. DisposeAsync()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.
public ValueTask DisposeAsync()
30.10.6.1.1. Returns
A task that represents the asynchronous dispose operation.
30.10.6.2. ~QueueMessageHandler()
protected ~QueueMessageHandler()