Skip to content
This repository was archived by the owner on Sep 2, 2021. It is now read-only.

Commit 7bee7a6

Browse files
SzymonPobiegaScooletz
authored andcommitted
Moved EnableFileBasedRouting to routing config. (#18)
1 parent a03808b commit 7bee7a6

4 files changed

Lines changed: 11 additions & 11 deletions

File tree

src/EndpointA/Program.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,7 @@ static async Task AsyncMain()
2424
var routingConfig = endpointConfiguration.UseTransport<MsmqTransport>().Routing();
2525
routingConfig.RegisterPublisher(typeof(DemoCommandReceived), "endpointB");
2626
routingConfig.InstanceMappingFile().FilePath("instance-mapping.xml");
27-
28-
endpointConfiguration.EnableFileBasedRouting();
27+
routingConfig.UseFileBasedRouting();
2928

3029
var endpoint = await Endpoint.Start(endpointConfiguration);
3130

src/EndpointB/Configuration.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,7 @@ public static async Task Start(string discriminator)
1818

1919
var routingConfig = endpointConfiguration.UseTransport<MsmqTransport>().Routing();
2020
routingConfig.RegisterPublisher(typeof(DemoEvent), "endpointA");
21-
22-
endpointConfiguration.EnableFileBasedRouting();
21+
routingConfig.UseFileBasedRouting();
2322

2423
var endpoint = await Endpoint.Start(endpointConfiguration);
2524

src/NServiceBus.FileBasedRouting.Tests/EndpointBasedIntegrationTests.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,15 +67,15 @@ static async Task<Func<Type,UnicastRoute>> GetRouting(string filePath)
6767
var endpointConfiguration = new EndpointConfiguration("test");
6868
endpointConfiguration.UsePersistence<InMemoryPersistence>();
6969
endpointConfiguration.SendFailedMessagesTo("error");
70-
endpointConfiguration.UseTransport<MsmqTransport>();
70+
var routing = endpointConfiguration.UseTransport<MsmqTransport>().Routing();
7171

7272
if (filePath == null)
7373
{
74-
endpointConfiguration.EnableFileBasedRouting();
74+
routing.UseFileBasedRouting();
7575
}
7676
else
7777
{
78-
endpointConfiguration.EnableFileBasedRouting(filePath);
78+
routing.UseFileBasedRouting(filePath);
7979
}
8080

8181
await Endpoint.Create(endpointConfiguration); // to init all features

src/NServiceBus.FileBasedRouting/FileBasedRoutingConfigExtensions.cs

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,26 +2,28 @@
22

33
namespace NServiceBus.FileBasedRouting
44
{
5+
using Features;
6+
57
public static class FileBasedRoutingConfigExtensions
68
{
79
/// <summary>
810
/// Enables routing configured with the routing configuration file.
911
/// </summary>
1012
/// <param name="config">The configuration object.</param>
11-
public static void EnableFileBasedRouting(this EndpointConfiguration config)
13+
public static void UseFileBasedRouting(this RoutingSettings config)
1214
{
13-
config.EnableFeature<FileBasedRoutingFeature>();
15+
config.GetSettings().EnableFeatureByDefault<FileBasedRoutingFeature>();
1416
}
1517

1618
/// <summary>
1719
/// Enables routing configured with the routing configuration file under <paramref name="configurationFilePath"/>
1820
/// </summary>
1921
/// <param name="config">The configuration object.</param>
2022
/// <param name="configurationFilePath">The path to the configuration file.</param>
21-
public static void EnableFileBasedRouting(this EndpointConfiguration config, string configurationFilePath)
23+
public static void UseFileBasedRouting(this RoutingSettings config, string configurationFilePath)
2224
{
2325
config.GetSettings().Set(FileBasedRoutingFeature.RoutingFilePathKey, configurationFilePath);
24-
config.EnableFeature<FileBasedRoutingFeature>();
26+
config.GetSettings().EnableFeatureByDefault<FileBasedRoutingFeature>();
2527
}
2628
}
2729
}

0 commit comments

Comments
 (0)