diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Models/MessageModel.cs b/src/activities/Elsa.Activities.AzureServiceBus/Models/MessageModel.cs
index 3e7562dab..5da5cd0d0 100644
--- a/src/activities/Elsa.Activities.AzureServiceBus/Models/MessageModel.cs
+++ b/src/activities/Elsa.Activities.AzureServiceBus/Models/MessageModel.cs
@@ -1,4 +1,5 @@
-using System;
+using System;
+using System.Collections.Generic;
 
 namespace Elsa.Activities.AzureServiceBus.Models
 {
@@ -18,5 +19,6 @@ namespace Elsa.Activities.AzureServiceBus.Models
         public TimeSpan TimeToLive { get; set; }
         public string? ReplyToSessionId { get; set; }
         public DateTime ScheduledEnqueueTimeUtc { get; set; }
+        public IDictionary<string, object> UserProperties { get; set; } = new Dictionary<string,object>();
     }
 }
\ No newline at end of file
diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs b/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs
index c9e7a1163..9eeac8426 100644
--- a/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs
+++ b/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs
@@ -1,4 +1,5 @@
-using System;
+using System;
+using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
 using Elsa.Activities.AzureServiceBus.Models;
@@ -66,7 +67,8 @@ namespace Elsa.Activities.AzureServiceBus.Services
                 ExpiresAtUtc = message.ExpiresAtUtc,
                 TimeToLive = message.TimeToLive,
                 ReplyToSessionId = message.ReplyToSessionId,
-                ScheduledEnqueueTimeUtc = message.ScheduledEnqueueTimeUtc
+                ScheduledEnqueueTimeUtc = message.ScheduledEnqueueTimeUtc,
+                UserProperties = new Dictionary<string, object>(message.UserProperties),
             };
 
             var bookmark = CreateBookmark(message);