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

give access to Service bus Message UserProperties

Browse source
This commit is contained in:
jdevillard 2021-04-15 10:04:37 +02:00 committed by Sipke Schoorstra
parent 4b6bc659dd
commit 1bccef163d
2 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/activities/Elsa.Activities.AzureServiceBus/Models/MessageModel.cs
View file

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

6
src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs
View file

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