ServiceBus: Add property FirstAquirer to IncomingMessage

helsenorge · Sep 20, 2022 · 1d8f556 · 1d8f556
1 parent 4f771ce
commit 1d8f556
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git 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
@@ -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,
                 };