diff --git a/src/modules/Elsa.Modules.AzureServiceBus/Activities/MessageReceived.cs b/src/modules/Elsa.Modules.AzureServiceBus/Activities/MessageReceived.cs
index 9ba5e6e2c..8ad85e277 100644
--- a/src/modules/Elsa.Modules.AzureServiceBus/Activities/MessageReceived.cs
+++ b/src/modules/Elsa.Modules.AzureServiceBus/Activities/MessageReceived.cs
@@ -43,7 +43,7 @@ public class MessageReceived : Trigger
     private async ValueTask Resume(ActivityExecutionContext context)
     {
         var receivedMessage = (ReceivedServiceBusMessageModel)context.WorkflowExecutionContext.Input[MessageReceivedInputKey]!;
-        var bodyAsString = receivedMessage.Body.ToString() ?? "";
+        var bodyAsString =  new BinaryData(receivedMessage.Body).ToString();
         var targetType = context.Get(ExpectedMessageType);
         var body = Formatter == null ? bodyAsString : await Formatter.FromStringAsync(bodyAsString, targetType, context.CancellationToken);