SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Update MessageReceived.cs

Browse source
This commit is contained in:
Sipke Schoorstra 2022-03-07 15:05:14 +01:00
parent c520a5e6d0
commit 3160ccb6ae
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/modules/Elsa.Modules.AzureServiceBus/Activities/MessageReceived.cs
View file

@ -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);