fix: use sub directories for path selectors

dbosoft · Feb 27, 2023 · 4170c66 · 4170c66
1 parent 9abaa8f
commit 4170c66
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultRebusDataBusSelector.cs b/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultRebusDataBusSelector.cs
@@ -1,4 +1,5 @@
 using System;
+using System.IO;
 using JetBrains.Annotations;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
@@ -35,7 +36,7 @@ protected override void ConfigureByType(string busType, StandardConfigurer<IData
 
                 if (path == null)
                     throw new InvalidOperationException($"Missing configuration entry for {ConfigurationName}::path.");
-                configurer.StoreInFileSystem(path);
+                configurer.StoreInFileSystem(Path.Combine(path, "databus"));
                 return;
 
             case "inmemory":

diff --git a/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultSagaStoreSelector.cs b/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultSagaStoreSelector.cs
@@ -1,4 +1,5 @@
 using System;
+using System.IO;
 using JetBrains.Annotations;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
@@ -36,7 +37,7 @@ protected override void ConfigureByType(string busType, StandardConfigurer<ISaga
                 if(path == null)
                     throw new InvalidOperationException($"Missing configuration entry for {ConfigurationName}::path.");
 
-                configurer.UseFilesystem(path);
+                configurer.UseFilesystem(Path.Combine(path, "sagas"));
                 return;
         }
     }

diff --git a/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTimeoutStoreSelector.cs b/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTimeoutStoreSelector.cs
@@ -1,4 +1,5 @@
 using System;
+using System.IO;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
 using Rebus.Config;
@@ -31,7 +32,7 @@ protected override void ConfigureByType(string busType, StandardConfigurer<ITime
                 if(path == null)
                     throw new InvalidOperationException($"Missing configuration entry for {ConfigurationName}::path.");
 
-                configurer.UseFileSystem(path);
+                configurer.UseFileSystem(Path.Combine(path, "timeouts"));
                 break;
         }
     }

diff --git a/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTransportSelector.cs b/src/Rebus.Configuration/Rebus.Configuration.Selectors/DefaultTransportSelector.cs
@@ -1,4 +1,5 @@
 using System;
+using System.IO;
 using JetBrains.Annotations;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
@@ -31,7 +32,7 @@ protected override void ConfigureBusType(string busType, string queueName, Stand
                 if (path == null)
                     throw new InvalidOperationException($"Missing configuration entry for {ConfigurationName}::path.");
 
-                configurer.UseFileSystem(path, queueName);
+                configurer.UseFileSystem(Path.Combine(path, "transport"), queueName);
                 return;
             case "inmemory":
                 configurer.UseInMemoryTransport(_network, queueName);