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

Add Defer method to CommandSender

Browse source
This commit is contained in:
Sipke Schoorstra 2021-01-28 09:28:45 +01:00
parent f6c58a9b6c
commit d593194457
2 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/core/Elsa.Abstractions/Services/ICommandSender.cs
View file

@ -1,10 +1,12 @@
using System.Collections.Generic;
using System.Threading.Tasks;
using NodaTime;
namespace Elsa.Services
{
public interface ICommandSender
{
Task SendAsync(object message, IDictionary<string, string>? headers = default);
Task DeferAsync(object message, Duration delay, IDictionary<string, string>? headers = default);
}
}

7
src/core/Elsa.Core/Services/CommandSender.cs
View file

@ -1,5 +1,6 @@
using System.Collections.Generic;
using System.Threading.Tasks;
using NodaTime;
namespace Elsa.Services
{
@ -17,5 +18,11 @@ namespace Elsa.Services
var bus = await _serviceBusFactory.GetServiceBusAsync(message.GetType(), default);
await bus.Send(message, headers);
}
public async Task DeferAsync(object message, Duration delay, IDictionary<string, string>? headers = default)
{
var bus = await _serviceBusFactory.GetServiceBusAsync(message.GetType(), default);
await bus.Defer(delay.ToTimeSpan(), message, headers);
}
}
}