diff --git a/README.md b/README.md index 80d9b59..49f3540 100644 --- a/README.md +++ b/README.md @@ -1,6 +1,6 @@ # dbosoft Rebus Extensions -This repository will contain following extensions to [Rebus](https://github.com/rebus-org/rebus): +This repository contains following extensions to [Rebus](https://github.com/rebus-org/rebus): - Dbosoft.Rebus.Configuration A extension for configuring rebus via dependency injection. @@ -9,4 +9,3 @@ This repository will contain following extensions to [Rebus](https://github.com/ A extension that uses rebus sagas to manage long running operations. -Development is in progress and no public release is currently available. diff --git a/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTimeoutStoreSelector.cs b/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTimeoutStoreSelector.cs index 50b9936..3ff9d48 100644 --- a/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTimeoutStoreSelector.cs +++ b/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTimeoutStoreSelector.cs @@ -1,6 +1,8 @@ -using Microsoft.Extensions.Configuration; +using System; +using Microsoft.Extensions.Configuration; using Microsoft.Extensions.Logging; using Rebus.Config; +using Rebus.Persistence.FileSystem; using Rebus.Persistence.InMem; using Rebus.Timeouts; @@ -13,7 +15,7 @@ public DefaultTimeoutsStoreSelector(IConfiguration configuration, ILogger log) : { } - public override string[] AcceptedConfigTypes => new []{"inmemory" }; + public override string[] AcceptedConfigTypes => new []{"inmemory", "filesystem" }; public override string ConfigurationName => "store"; protected override void ConfigureByType(string busType, StandardConfigurer configurer) @@ -23,6 +25,14 @@ protected override void ConfigureByType(string busType, StandardConfigurer).MakeGenericType(messageType), command, task.OperationId, task.InitiatingTaskId, task.Id); - _bus.SendLocal(outboundMessage); + return _bus.SendLocal(outboundMessage); } public Task DispatchTaskStatusEventAsync(string commandType, OperationTaskStatusEvent message)