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

Configure Rebus activities

Browse source
This commit is contained in:
Sipke Schoorstra 2021-04-03 22:04:35 +02:00
parent 12c57de73c
commit ac8ddf2f00
2 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/activities/Elsa.Activities.Rebus/Activities/PublishRebusMessage.cs
View file

@ -2,6 +2,8 @@
using System.Threading.Tasks;
using Elsa.ActivityResults;
using Elsa.Attributes;
using Elsa.Design;
using Elsa.Expressions;
using Elsa.Services;
using Elsa.Services.Models;
@ -17,10 +19,10 @@ namespace Elsa.Activities.Rebus
_eventPublisher = eventPublisher;
}
[ActivityProperty(Hint = "The message to publish.")]
[ActivityProperty(Hint = "The message to publish.", SupportedSyntaxes = new[] { SyntaxNames.JavaScript, SyntaxNames.Liquid })]
public object Message { get; set; } = default!;
[ActivityProperty(Hint = "Optional headers to send along with the message.")]
[ActivityProperty(Hint = "Optional headers to send along with the message.", UIHint = ActivityPropertyUIHints.Json)]
public IDictionary<string, string>? Headers { get; set; }
protected override async ValueTask<IActivityExecutionResult> OnExecuteAsync(ActivityExecutionContext context)

6
src/activities/Elsa.Activities.Rebus/Activities/SendRebusMessage.cs
View file

@ -2,6 +2,8 @@
using System.Threading.Tasks;
using Elsa.ActivityResults;
using Elsa.Attributes;
using Elsa.Design;
using Elsa.Expressions;
using Elsa.Services;
using Elsa.Services.Models;
@ -17,10 +19,10 @@ namespace Elsa.Activities.Rebus
_bus = bus;
}
[ActivityProperty(Hint = "The message to send.")]
[ActivityProperty(Hint = "The message to send.", SupportedSyntaxes = new[] { SyntaxNames.JavaScript, SyntaxNames.Liquid })]
public object Message { get; set; } = default!;
[ActivityProperty(Hint = "Optional headers to send along with the message.")]
[ActivityProperty(Hint = "Optional headers to send along with the message.", UIHint = ActivityPropertyUIHints.Json)]
public IDictionary<string, string>? Headers { get; set; }
protected override async ValueTask<IActivityExecutionResult> OnExecuteAsync(ActivityExecutionContext context)