Is there a timeout for mediator consumers ?

[alefcarlos]

We have some usecases(reports) that take more than 30 seconds to process and then an exception is thrown:

      R-FAULT loopback://localhost/mediator e4630000-0ffe-0009-5f73-08dc75dd2274 Sample.Controllers.Query Sample.Controllers.GetHandler(00:00:30.3194957)
      MassTransit.MessageNotConsumedException: loopback://localhost/response => The message was not consumed
         at MassTransit.Middleware.FaultDeadLetterFilter.Send(ReceiveContext context, IPipe`1 next) in /_/src/MassTransit/Middleware/FaultDeadLetterFilter.cs:line 11
         at MassTransit.Configuration.PipeConfigurator`1.FilterPipe.Send(TContext context) in /_/src/MassTransit.Abstractions/Middleware/Configuration/PipeBuilder.cs:line 97

Is there any way to configure the handler process time like JobConsumer ?

I created a sample handler:

    public override async Task<Result<IEnumerable<WeatherForecast>>> Handle(Query request, CancellationToken cancellationToken)
    {
        if (request.Delay)
            await Task.Delay(TimeSpan.FromSeconds(30), cancellationToken);

        return Success(Enumerable.Range(1, 5).Select(index => new WeatherForecast
        {
            Date = DateOnly.FromDateTime(DateTime.Now.AddDays(index)),
            TemperatureC = Random.Shared.Next(-20, 55),
            Summary = Summaries[Random.Shared.Next(Summaries.Length)]
        })
        .ToArray());
    }

Any delay less than 30 seconds does not throw exception

[phatboyg]

I don't know of a timeout as far as Mediator is concerned, beyond the cancellationToken passed to Send or Publish.

[alefcarlos]

I see, but is that a expected behavior?

[phatboyg]

I don't understand what you're asking, if you have a complete example share the GitHub repository.

[alefcarlos]

The mediator consumer has thrown Exception after x seconds. I pushed the sample repo:

https://github.com/alefcarlos/poc-mediator-masstransit/blob/2b093baa4877c1c0f58d29ac3dd01477065d991a/src/SampleMasstransit/Query.cs#L22

[phatboyg]

Ah, wel, yeah. The default request timeout is 30 seconds. And it seems like SendRequest doesn't have a way to specify a requestTimeout.

MassTransit/src/MassTransit.Abstractions/MediatorRequestExtensions.cs

Line 24 in 99f4fb1

using RequestHandle<Request<T>> handle = mediator.CreateRequest(request, cancellationToken);

[phatboyg]

I'll add the ability to specify the timeout.