DurableMediator 2.1.0

.NET 6.0
dotnet add package DurableMediator --version 2.1.0
NuGet\Install-Package DurableMediator -Version 2.1.0
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="DurableMediator" Version="2.1.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add DurableMediator --version 2.1.0
#r "nuget: DurableMediator, 2.1.0"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install DurableMediator as a Cake Addin
#addin nuget:?package=DurableMediator&version=2.1.0

// Install DurableMediator as a Cake Tool
#tool nuget:?package=DurableMediator&version=2.1.0

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
    public string WorkflowName => "Human readable workflow name";
    public string InstanceId => SomeId.ToString();

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 async Task<Unit> OrchestrateAsync(IWorkflowExecution<WorkflowRequest> execution)
        var logger = execution.OrchestrationContext.CreateReplaySafeLogger(_logger);

        logger.LogInformation("Start with workflow");

        await execution.ExecuteAsync(new MediatorRequest(execution.Request.SomeId));

        logger.LogInformation("Workflow done");

        return Unit.Value;

Create a Azure Function that triggers this workflow:

public static class 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 execution.ExecuteAsync 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 execution 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 execution also exposes methods from ISubWorkflowOrchestrator, which allows workflows to initiate other workflows, and even await their responses, making it easy to compose workflows.


See the WorkflowFunctionApp in the example folder for more examples.

Preview: Activity history and durable entities

Use builder.AddDurableMediator(useExperimentalEntityExecution: true, typeof(Startup)); to enable entity execution which allows for:

  • Enable capturing request and response data to and from durable mediator invocations. This allows IWorkflowManagement.GetWorkflowAsync to output that data, making it possible to access the exact requests and responses after the workflow has completed.

The downside of this way feature is that every workflow will create a durable entity history record. This record will be stored in the orchestration history storage (under @durablemediator@{instanceId}) and needs to be cleared using IDurableEntityClient.CleanEntityStorageAsync.

Product Versions
.NET net6.0 net6.0-android net6.0-ios net6.0-maccatalyst net6.0-macos net6.0-tvos net6.0-windows net7.0 net7.0-android net7.0-ios net7.0-maccatalyst net7.0-macos net7.0-tvos net7.0-windows
Compatible target framework(s)
Additional computed target framework(s)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
2.1.0 162 12/20/2022
2.0.0 224 11/1/2022
1.2.0 285 9/20/2022
1.1.0 348 7/12/2022
1.0.2 348 4/26/2022
1.0.1 335 4/26/2022
1.0.0 360 4/26/2022