diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusMessageReceived/AzureServiceBusQueueMessageReceived.cs b/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusMessageReceived/AzureServiceBusQueueMessageReceived.cs
index e5ebb3a82..21091dd09 100644
--- a/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusMessageReceived/AzureServiceBusQueueMessageReceived.cs
+++ b/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusMessageReceived/AzureServiceBusQueueMessageReceived.cs
@@ -25,6 +25,9 @@ namespace Elsa.Activities.AzureServiceBus
 
         [ActivityInput]
         public Type MessageType { get; set; } = default!;
+        
+        [ActivityOutput]
+        public object? ReceivedMessage { get; set; }
 
         protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context) => context.WorkflowExecutionContext.IsFirstPass ? ExecuteInternal(context) : Suspend();
         protected override IActivityExecutionResult OnResume(ActivityExecutionContext context) => ExecuteInternal(context);
@@ -34,6 +37,7 @@ namespace Elsa.Activities.AzureServiceBus
             var message = (MessageModel) context.Input!;
             var model = message.ReadBody(MessageType, _serializer);
 
+            ReceivedMessage = model;
             return Done(model);
         }
     }
diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusTopicMessageReceived/AzureServiceBusTopicMessageReceived.cs b/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusTopicMessageReceived/AzureServiceBusTopicMessageReceived.cs
index 417d56a09..907a0f19e 100644
--- a/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusTopicMessageReceived/AzureServiceBusTopicMessageReceived.cs
+++ b/src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusTopicMessageReceived/AzureServiceBusTopicMessageReceived.cs
@@ -30,6 +30,9 @@ namespace Elsa.Activities.AzureServiceBus
 
         [ActivityInput]
         public Type MessageType { get; set; } = default!;
+        
+        [ActivityOutput]
+        public object? ReceivedMessage { get; set; }
 
         protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context) => context.WorkflowExecutionContext.IsFirstPass ? ExecuteInternal(context) : Suspend();
         protected override IActivityExecutionResult OnResume(ActivityExecutionContext context) => ExecuteInternal(context);
@@ -39,6 +42,7 @@ namespace Elsa.Activities.AzureServiceBus
             var message = (MessageModel) context.Input!;
             var model = message.ReadBody(MessageType, _serializer);
 
+            ReceivedMessage = model;
             return Done(model);
         }
     }