by-pinja#39: Allow adding Arrival to be configured

toka-p · Dec 15, 2022 · 0d1ca7b · 0d1ca7b
1 parent 0c461d4
commit 0d1ca7b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/Protacon.RxMq.AzureServiceBus/Topic/AzureTopicMqSettings.cs b/Protacon.RxMq.AzureServiceBus/Topic/AzureTopicMqSettings.cs
@@ -8,6 +8,7 @@ namespace Protacon.RxMq.AzureServiceBus.Topic
     public class AzureBusTopicSettings : AzureMqSettingsBase
     {
         public string TopicSubscriberId { get; set; } = Environment.MachineName;
+        public bool AddArrival { get; set; }
 
         public Func<Type, string> TopicNameBuilder { get; set; } = type =>
         {

diff --git a/Protacon.RxMq.AzureServiceBus/Topic/AzureTopicSubscriber.cs b/Protacon.RxMq.AzureServiceBus/Topic/AzureTopicSubscriber.cs
@@ -45,7 +45,13 @@ internal Binding(AzureBusTopicSettings settings, ILogger<AzureTopicSubscriber> l
                     {
                         try
                         {
-                            var arrival = DateTimeOffset.UtcNow;
+                            DateTimeOffset arrival;
+
+                            if (settings.AddArrival)
+                            {
+                                arrival = DateTimeOffset.UtcNow;
+                            }
+
                             var body = Encoding.UTF8.GetString(message.Body);
 
                             if (!_excludeTopicsFromLogging.Contains(topicName))