Masstransit-schedule-timeout

ScheduleTimeout.cs

var configuredDelay = TimeSpan.FromMinutes(30);

Schedule( () => ActivityCompletionTimeout, 
  instance => instance.ActivityCompletionTimeoutTokenId,
  s =>    
  {
    s.Delay = configuredDelay;       
    s.Received = r    => r.CorrelateById(context => context.Message.SagaId);
  });


During(Initial,
  When(Start)
  .Activity(x => x.OfType<Activity>())
  .TransitionTo(NextState)
  .Execute( context => new PublishNextCommand(howMany))
  .Schedule(ActivityCompletionTimeout, 
    ctx => ctx.Init<ActivityCompletionTimeoutExpired>(
      new {
        SagaId = ctx.Instance.CorrelationId, 
        ctx.Instance.CorrelationId,
        CommandName = nameof(PublishNextCommand)
        }
    )
    , ctx => configuredDelay)); // Thought this would set the timeout for the ActivityCompletionTimeout to 30 minutes.