工作流基础:永不完成的延迟活动

让我们有一个由接收活动和延迟活动组成的工作流。 接收活动具有 CanCreateInstance = true 并提供了查询(消息)关联。 工作流托管在工作流服务中 并在空闲时立即保存到数据库中。

WorkflowService service = new WorkflowService
{
  Name = "MyWorkflow",
  Body = new MyWorkflow(),
  Endpoints =
  {
    new Endpoint
    {
      ServiceContractName = "IMyWorkflow",
      AddressUri = new Uri("http://localhost:1234/MyWorkflow"),
      Binding = new BasicHttpBinding()
    }
  }
};

WorkflowServiceHost host = new WorkflowServiceHost(service);
string conn = "Data Source=...;Initial Catalog=...";
host.DurableInstancingOptions.InstanceStore = new SqlWorkflowInstanceStore(conn);
host.Open();

现在我将消息发送到工作流 运行时创建第一个工作流实例。 当然,相关键包含在消息中。 工作流继续执行延迟活动 并保存到数据库并卸载。

假设延迟时间足够长,我将发送下一条消息 具有完全相同的相关键。发生什么事了? 两个工作流都不会从延迟中唤醒,也不会完成。

我做错什么了? 为什么工作流运行时不保护我不受此影响? 是否有任何方法可以挽救这两个工作流实例?

谢谢你的帮助!