MongoDB Persistence provider for Workflow Core

Provides support to persist workflows running on Workflow Core to a MongoDB database.

Installing

Install the NuGet package “WorkflowCore.Persistence.MongoDB”

PM> Install-Package WorkflowCore.Persistence.MongoDB

Usage

Use the .UseMongoDB extension method when building your service provider.

services.AddWorkflow(x => x.UseMongoDB(@"mongodb://localhost:27017", "workflow"));

State object serialization

By default (to maintain backwards compatibility), the state object is serialized using a two step serialization process using object -> JSON -> BSON serialization. This approach has some limitations, for example you cannot control which types will be used in MongoDB for particular fields and you cannot use basic types that are not present in JSON (decimal, timestamp, etc).

To eliminate these limitations, you can use a direct object -> BSON serialization and utilize all serialization possibilities that MongoDb driver provides. You can read more in the MongoDb CSharp documentation. To enable direct serilization you need to register a class map for you state class somewhere in your startup process before you run WorkflowHost.

private void RunWorkflow()
{
    var host = this._serviceProvider.GetService<IWorkflowHost>();
    if (host == null)
    {
        return;
    }

    if (!BsonClassMap.IsClassMapRegistered(typeof(MyWorkflowState)))
    {
        BsonClassMap.RegisterClassMap<MyWorkflowState>(cm =>
        {
            cm.AutoMap();
        });
    }

    host.RegisterWorkflow<MyWorkflow, MyWorkflowState>();

    host.Start();
}