Skip to content

Commit

Permalink
Merge pull request #556 from Particular/namespace-update
Browse files Browse the repository at this point in the history
Move settings into NServiceBus namespace
  • Loading branch information
danielmarbach authored Feb 5, 2020
2 parents 8b36c27 + e6a1b9e commit 34c1691
Show file tree
Hide file tree
Showing 25 changed files with 48 additions and 63 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -5,26 +5,6 @@
[assembly: System.Runtime.InteropServices.ComVisibleAttribute(false)]
namespace NServiceBus
{
public class SqlServerTransport : NServiceBus.Transport.TransportDefinition
{
public SqlServerTransport() { }
public override string ExampleConnectionStringForErrorMessage { get; }
public override bool RequiresConnectionString { get; }
public override NServiceBus.Transport.TransportInfrastructure Initialize(NServiceBus.Settings.SettingsHolder settings, string connectionString) { }
}
}
namespace NServiceBus.Transport.SqlServer
{
public class DelayedDeliverySettings : NServiceBus.Configuration.AdvancedExtensibility.ExposeSettings
{
public void BatchSize(int batchSize) { }
[System.ObsoleteAttribute("Compatibility with the timeout manager is now disabled by default. The member cur" +
"rently throws a NotImplementedException. Will be removed in version 7.0.0.", true)]
public void DisableTimeoutManagerCompatibility() { }
public void EnableTimeoutManagerCompatibility() { }
public void ProcessingInterval(System.TimeSpan interval) { }
public void TableSuffix(string suffix) { }
}
public class static MessageDrivenPubSubCompatibilityModeConfiguration
{
public static NServiceBus.SubscriptionMigrationModeSettings EnableMessageDrivenPubSubCompatibilityMode(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions) { }
Expand All @@ -33,6 +13,13 @@ namespace NServiceBus.Transport.SqlServer
{
public static void UseCustomSqlTransaction(this NServiceBus.SendOptions options, System.Data.SqlClient.SqlTransaction transaction) { }
}
public class SqlServerTransport : NServiceBus.Transport.TransportDefinition
{
public SqlServerTransport() { }
public override string ExampleConnectionStringForErrorMessage { get; }
public override bool RequiresConnectionString { get; }
public override NServiceBus.Transport.TransportInfrastructure Initialize(NServiceBus.Settings.SettingsHolder settings, string connectionString) { }
}
public class static SqlServerTransportSettingsExtensions
{
public static NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> CreateMessageBodyComputedColumn(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions) { }
Expand All @@ -49,6 +36,19 @@ namespace NServiceBus.Transport.SqlServer
public static NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> UseSchemaForQueue(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions, string queueName, string schema) { }
public static NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> WithPeekDelay(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions, System.Nullable<System.TimeSpan> delay = null) { }
}
}
namespace NServiceBus.Transport.SqlServer
{
public class DelayedDeliverySettings : NServiceBus.Configuration.AdvancedExtensibility.ExposeSettings
{
public void BatchSize(int batchSize) { }
[System.ObsoleteAttribute("Compatibility with the timeout manager is now disabled by default. The member cur" +
"rently throws a NotImplementedException. Will be removed in version 7.0.0.", true)]
public void DisableTimeoutManagerCompatibility() { }
public void EnableTimeoutManagerCompatibility() { }
public void ProcessingInterval(System.TimeSpan interval) { }
public void TableSuffix(string suffix) { }
}
public class SubscriptionSettings
{
public SubscriptionSettings() { }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
using AcceptanceTesting.Customization;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_catalog_configured_for_endpoint : MultiCatalogAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
using AcceptanceTesting;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_catalog_configured_for_error_queue : MultiCatalogAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
using Configuration.AdvancedExtensibility;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_catalog_configured_for_legacy_publisher : MultiCatalogAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
using Features;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_catalog_configured_for_publisher_and_subscriber : MultiCatalogAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
using AcceptanceTesting;
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using SqlServer;

public abstract class When_custom_schema_configured_for_endpoint : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
using AcceptanceTesting;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

using static AcceptanceTesting.Customization.Conventions;

public class When_custom_schema_configured_for_endpoint_with_brackets_syntax : When_custom_schema_configured_for_endpoint
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
using AcceptanceTesting.Customization;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_schema_configured_for_endpoint_with_default_override : When_custom_schema_configured_for_endpoint
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
using AcceptanceTesting;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

using static AcceptanceTesting.Customization.Conventions;

public class When_custom_schema_configured_for_endpoint_with_queue_specific_override : When_custom_schema_configured_for_endpoint
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_schema_configured_for_error_queue : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_schema_configured_for_legacy_publisher : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_schema_configured_for_publisher_and_subscriber : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_custom_schema_contains_at : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using Routing.MessageDrivenSubscriptions;
using SqlServer;

public class When_publisher_runs_in_compat_mode : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_subscriber_runs_in_compat_mode : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_deferring_a_message_in_timeout_manager_compatibility_mode : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_customizing_scope_isolation_level : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_using_scope_timeout_greater_than_machine_max : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_passing_custom_transaction_via_sendoptions : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_using_computed_message_body_column : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
using NServiceBus.AcceptanceTests;
using NServiceBus.AcceptanceTests.EndpointTemplates;
using NUnit.Framework;
using SqlServer;

public class When_using_custom_connection_factory : NServiceBusAcceptanceTest
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,26 +5,6 @@
[assembly: System.Runtime.InteropServices.ComVisibleAttribute(false)]
namespace NServiceBus
{
public class SqlServerTransport : NServiceBus.Transport.TransportDefinition
{
public SqlServerTransport() { }
public override string ExampleConnectionStringForErrorMessage { get; }
public override bool RequiresConnectionString { get; }
public override NServiceBus.Transport.TransportInfrastructure Initialize(NServiceBus.Settings.SettingsHolder settings, string connectionString) { }
}
}
namespace NServiceBus.Transport.SqlServer
{
public class DelayedDeliverySettings : NServiceBus.Configuration.AdvancedExtensibility.ExposeSettings
{
public void BatchSize(int batchSize) { }
[System.ObsoleteAttribute("Compatibility with the timeout manager is now disabled by default. The member cur" +
"rently throws a NotImplementedException. Will be removed in version 7.0.0.", true)]
public void DisableTimeoutManagerCompatibility() { }
public void EnableTimeoutManagerCompatibility() { }
public void ProcessingInterval(System.TimeSpan interval) { }
public void TableSuffix(string suffix) { }
}
public class static MessageDrivenPubSubCompatibilityModeConfiguration
{
public static NServiceBus.SubscriptionMigrationModeSettings EnableMessageDrivenPubSubCompatibilityMode(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions) { }
Expand All @@ -33,6 +13,13 @@ namespace NServiceBus.Transport.SqlServer
{
public static void UseCustomSqlTransaction(this NServiceBus.SendOptions options, Microsoft.Data.SqlClient.SqlTransaction transaction) { }
}
public class SqlServerTransport : NServiceBus.Transport.TransportDefinition
{
public SqlServerTransport() { }
public override string ExampleConnectionStringForErrorMessage { get; }
public override bool RequiresConnectionString { get; }
public override NServiceBus.Transport.TransportInfrastructure Initialize(NServiceBus.Settings.SettingsHolder settings, string connectionString) { }
}
public class static SqlServerTransportSettingsExtensions
{
public static NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> CreateMessageBodyComputedColumn(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions) { }
Expand All @@ -49,6 +36,19 @@ namespace NServiceBus.Transport.SqlServer
public static NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> UseSchemaForQueue(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions, string queueName, string schema) { }
public static NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> WithPeekDelay(this NServiceBus.TransportExtensions<NServiceBus.SqlServerTransport> transportExtensions, System.Nullable<System.TimeSpan> delay = null) { }
}
}
namespace NServiceBus.Transport.SqlServer
{
public class DelayedDeliverySettings : NServiceBus.Configuration.AdvancedExtensibility.ExposeSettings
{
public void BatchSize(int batchSize) { }
[System.ObsoleteAttribute("Compatibility with the timeout manager is now disabled by default. The member cur" +
"rently throws a NotImplementedException. Will be removed in version 7.0.0.", true)]
public void DisableTimeoutManagerCompatibility() { }
public void EnableTimeoutManagerCompatibility() { }
public void ProcessingInterval(System.TimeSpan interval) { }
public void TableSuffix(string suffix) { }
}
public class SubscriptionSettings
{
public SubscriptionSettings() { }
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace NServiceBus.Transport.SqlServer
namespace NServiceBus
{
using Configuration.AdvancedExtensibility;

Expand Down
4 changes: 3 additions & 1 deletion src/NServiceBus.Transport.SqlServer/SendOptionsExtensions.cs
Original file line number Diff line number Diff line change
@@ -1,11 +1,13 @@
namespace NServiceBus.Transport.SqlServer
namespace NServiceBus
{
#if SYSTEMDATASQLCLIENT
using System.Data.SqlClient;
#else
using Microsoft.Data.SqlClient;
#endif
using Extensibility;
using Transport;
using Transport.SqlServer;

/// <summary>
/// Adds transport specific settings to SendOptions
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace NServiceBus.Transport.SqlServer
namespace NServiceBus
{
using System;
#if SYSTEMDATASQLCLIENT
Expand All @@ -10,6 +10,7 @@
using System.Transactions;
using Configuration.AdvancedExtensibility;
using Logging;
using Transport.SqlServer;

/// <summary>
/// Adds extra configuration for the Sql Server transport.
Expand Down

0 comments on commit 34c1691

Please sign in to comment.