From 1d8f5566e0746792280d516641e1ea3d46f02531 Mon Sep 17 00:00:00 2001
From: Kenneth Myhra <kennethmyhra@gmail.com>
Date: Tue, 20 Sep 2022 11:26:08 +0200
Subject: [PATCH] ServiceBus: Add property FirstAquirer to IncomingMessage

---
 src/Helsenorge.Messaging/Abstractions/IncomingMessage.cs      | 4 ++++
 .../ServiceBus/Receivers/MessageListener.cs                   | 2 ++
 2 files changed, 6 insertions(+)

diff --git a/src/Helsenorge.Messaging/Abstractions/IncomingMessage.cs b/src/Helsenorge.Messaging/Abstractions/IncomingMessage.cs
index 424dc4d5..6a3d3975 100644
--- a/src/Helsenorge.Messaging/Abstractions/IncomingMessage.cs
+++ b/src/Helsenorge.Messaging/Abstractions/IncomingMessage.cs
@@ -99,6 +99,10 @@ public class IncomingMessage
         /// </summary>
         public Func<Task> DeadletterAsync { get; internal set; }
         /// <summary>
+        /// Returns true if this is the first time the message is aquried.
+        /// </summary>
+        public bool FirstAquirer { get; internal set; }
+        /// <summary>
         /// Gets the number of deliveries.
         /// </summary>
         public int DeliveryCount { get ; internal set; }
diff --git a/src/Helsenorge.Messaging/ServiceBus/Receivers/MessageListener.cs b/src/Helsenorge.Messaging/ServiceBus/Receivers/MessageListener.cs
index 327d83dd..6a042185 100644
--- a/src/Helsenorge.Messaging/ServiceBus/Receivers/MessageListener.cs
+++ b/src/Helsenorge.Messaging/ServiceBus/Receivers/MessageListener.cs
@@ -179,6 +179,8 @@ private async Task<IncomingMessage> HandleRawMessage(IMessagingMessage message,
                     ReleaseAsync = message.RelaseAsync,
                     Deadletter = message.DeadLetter,
                     DeadletterAsync = message.DeadLetterAsync,
+                    // FIXME: This will be moved to the interface IMessagingMessage in version 5.0
+                    FirstAquirer = (message as ServiceBusMessage)?.FirstAcquirer ?? false,
                     DeliveryCount = message.DeliveryCount,
                     LockedUntil = message.LockedUntil,
                 };