Added SessionIdResolver to scheduleAsync method

wemogy · Dec 5, 2023 · 0e3fc6f · 0e3fc6f
1 parent 989abb3
commit 0e3fc6f
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/src/core/Wemogy.CQRS/Commands/Abstractions/ICommands.cs b/src/core/Wemogy.CQRS/Commands/Abstractions/ICommands.cs
@@ -19,6 +19,9 @@ public interface ICommands
     Task<string> ScheduleAsync<TCommand>(TCommand command, TimeSpan delay = default)
         where TCommand : ICommandBase;
 
+    Task<string> ScheduleAsync<TCommand>(TCommand command, Func<TCommand, string> sessionIdResolver)
+        where TCommand : ICommandBase;
+
     Task<string> ScheduleAsync<TCommand>(TCommand command, DelayOptions<TCommand> delayOptions)
         where TCommand : ICommandBase;
 

diff --git a/src/core/Wemogy.CQRS/Commands/Mediators/CommandsMediator.cs b/src/core/Wemogy.CQRS/Commands/Mediators/CommandsMediator.cs
@@ -45,6 +45,12 @@ public Task<string> ScheduleAsync<TCommand>(TCommand command, TimeSpan delay = d
         return ScheduleAsync(command, new DelayOptions<TCommand>(delay));
     }
 
+    public Task<string> ScheduleAsync<TCommand>(TCommand command, Func<TCommand, string> sessionIdResolver)
+        where TCommand : ICommandBase
+    {
+        return ScheduleAsync(command, new DelayOptions<TCommand>(TimeSpan.Zero, sessionIdResolver));
+    }
+
     public Task<string> ScheduleAsync<TCommand>(TCommand command, DelayOptions<TCommand> delayOptions)
         where TCommand : ICommandBase
     {