DurableMediator 1.0.2
See the version list below for details.
dotnet add package DurableMediator --version 1.0.2
NuGet\Install-Package DurableMediator -Version 1.0.2
<PackageReference Include="DurableMediator" Version="1.0.2" />
paket add DurableMediator --version 1.0.2
#r "nuget: DurableMediator, 1.0.2"
// Install DurableMediator as a Cake Addin #addin nuget:?package=DurableMediator&version=1.0.2 // Install DurableMediator as a Cake Tool #tool nuget:?package=DurableMediator&version=1.0.2
Durable Mediator
Durable Mediator is an extension to the Durable Task library which allows for running MediatR Requests as activities in orchestrations without any complex ceremony.
Getting started
To get started with running orchestrations which call MediatR Requests as activities, which are called "Workflows", follow these steps:
First start by defining a workflow request:
public record WorkflowRequest(Guid SomeId) : IWorkflowRequest;
Also, create a IRequest
that needs to be called from the workflow:
public record MediatorRequest(Guid SomeId) : IRequest;
Create a request handler that handles this MediatR request:
public class MediatorRequestHandler : IRequestHandler<MediatorRequest>
{
private readonly ILogger<MediatorRequestHandler> _logger;
public RequestAHandler(ILogger<MediatorRequestHandler> logger)
{
_logger = logger;
}
public Task<Unit> Handle(MediatorRequest request, CancellationToken cancellationToken)
{
_logger.LogInformation("Processing RequestA");
return Task.FromResult(Unit.Value);
}
}
Create a workflow that handles the WorkflowRequest
:
public class ExampleWorkflow : IWorkflow<WorkflowRequest, Unit>
{
private readonly ILogger<ABCWorkflow> _logger;
public ExampleWorkflow(ILogger<ABCWorkflow> logger)
{
_logger = logger;
}
public string Name => "Human readable workflow name";
public async Task<Unit> OrchestrateAsync(WorkflowContext<WorkflowRequest> context)
{
var logger = context.OrchestrationContext.CreateReplaySafeLogger(_logger);
logger.LogInformation("Start with workflow");
await context.DurableMediator.SendAsync(new MediatorRequest(context.Request.SomeId));
logger.LogInformation("Workflow done");
return Unit.Value;
}
}
Create a Azure Function that triggers this workflow:
public static class WorkflowTrigger
{
[FunctionName(nameof(WorkflowTrigger))]
public static async Task<IActionResult> TriggerOrchestratorAsync(
[HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "workflow")] HttpRequestMessage req,
[Workflow] IWorkflowStarter starter)
{
var startDetails = await starter.StartNewAsync(new WorkflowRequest(Guid.NewGuid()));
return new AcceptedResult("", startDetails);
}
}
In your function app startup, add the required services by including builder.AddDurableMediator(typeof(Startup));
.
When running your function app you will see that next to the WorkflowTrigger Http Trigger function, an Orchestration Trigger function called "WorkflowRequest" and a "DurableMediatorEntity" Entity Trigger function are added. When http function triggers the start of the workflow, the orchestration function will orchestrate the workflow and invoke ExampleWorkflow
. Each call to the context.DurableMediator
will trigger the DurableMediatorEntity to execute the MediatR Request in a separate activity after which the orchestration resumes. No more calling context.CallActivity
and guessing what parameters to pass in.
The context
exposes the IDurableOrchestrationContext
from the Durable Task library, giving full access to creating timers for durable delays, locking entities for critical sections, or wait for external events. The context
also exposes a ISubWorkflowOrchestrator
, which allows workflows to initiate other workflows, and even await their responses, making it easy to compose workflows.
Examples
See the WorkflowFunctionApp in the example folder for more examples.
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
-
net6.0
- MediatR (>= 10.0.1)
- MediatR.Extensions.Microsoft.DependencyInjection (>= 10.0.1)
- Microsoft.Azure.Functions.Extensions (>= 1.1.0)
- Microsoft.Azure.WebJobs.Extensions.DurableTask (>= 2.6.1)
- Microsoft.Azure.WebJobs.Script.Abstractions (>= 1.0.0-preview)
- Microsoft.Extensions.Options.DataAnnotations (>= 6.0.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.