diff --git a/.gitignore b/.gitignore
index ef7a9f241f2..ab409099416 100644
--- a/.gitignore
+++ b/.gitignore
@@ -12,9 +12,11 @@ results
CommonAssemblyInfo.cs
lib/sqlite/System.Data.SQLite.dll
*.orig
+*.zip
Samples/DataBus/storage
packages
PrecompiledWeb
+tempstorage
core-only
Release
Artifacts
@@ -82,4 +84,8 @@ _ReSharper*/
src/scaffolding.config
# Approval tests temp file
-*.received.*
\ No newline at end of file
+*.received.*
+
+# JetBrains Rider
+.idea/
+*.sln.iml
\ No newline at end of file
diff --git a/GitVersion.yml b/GitVersion.yml
new file mode 100644
index 00000000000..5c932e69584
--- /dev/null
+++ b/GitVersion.yml
@@ -0,0 +1,7 @@
+assembly-versioning-scheme: Major
+next-version: 6.0
+branches:
+ develop:
+ tag: alpha
+ releases?[/-]:
+ tag: rc
\ No newline at end of file
diff --git a/GitVersionConfig.yaml b/GitVersionConfig.yaml
deleted file mode 100644
index 10b5dc97c04..00000000000
--- a/GitVersionConfig.yaml
+++ /dev/null
@@ -1 +0,0 @@
-assembly-versioning-scheme: Major
\ No newline at end of file
diff --git a/IntegrationTests/GenericHost/GenericHost.sln b/IntegrationTests/GenericHost/GenericHost.sln
deleted file mode 100644
index ee07a49583f..00000000000
--- a/IntegrationTests/GenericHost/GenericHost.sln
+++ /dev/null
@@ -1,28 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio 2013
-VisualStudioVersion = 12.0.30723.0
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Logging", "Logging\Logging.csproj", "{15E0163A-315E-4473-9BF3-DD9EA128EBD7}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "LoggingWithConfigurableThreshold", "LoggingWithConfigurableThreshold\LoggingWithConfigurableThreshold.csproj", "{3BF3849F-A0F5-4B9A-BB8F-12D4219F7787}"
-EndProject
-Global
- GlobalSection(SolutionConfigurationPlatforms) = preSolution
- Debug|Any CPU = Debug|Any CPU
- Release|Any CPU = Release|Any CPU
- EndGlobalSection
- GlobalSection(ProjectConfigurationPlatforms) = postSolution
- {15E0163A-315E-4473-9BF3-DD9EA128EBD7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {15E0163A-315E-4473-9BF3-DD9EA128EBD7}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {15E0163A-315E-4473-9BF3-DD9EA128EBD7}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {15E0163A-315E-4473-9BF3-DD9EA128EBD7}.Release|Any CPU.Build.0 = Release|Any CPU
- {3BF3849F-A0F5-4B9A-BB8F-12D4219F7787}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {3BF3849F-A0F5-4B9A-BB8F-12D4219F7787}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {3BF3849F-A0F5-4B9A-BB8F-12D4219F7787}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {3BF3849F-A0F5-4B9A-BB8F-12D4219F7787}.Release|Any CPU.Build.0 = Release|Any CPU
- EndGlobalSection
- GlobalSection(SolutionProperties) = preSolution
- HideSolutionNode = FALSE
- EndGlobalSection
-EndGlobal
diff --git a/IntegrationTests/GenericHost/Logging/App.config b/IntegrationTests/GenericHost/Logging/App.config
deleted file mode 100644
index 777836e80b2..00000000000
--- a/IntegrationTests/GenericHost/Logging/App.config
+++ /dev/null
@@ -1,11 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
diff --git a/IntegrationTests/GenericHost/Logging/Endpoint.cs b/IntegrationTests/GenericHost/Logging/Endpoint.cs
deleted file mode 100644
index c2749d91be4..00000000000
--- a/IntegrationTests/GenericHost/Logging/Endpoint.cs
+++ /dev/null
@@ -1,26 +0,0 @@
-using System;
-using NServiceBus;
-
-namespace Logging
-{
- /* In this sample, we want our own production logging while leaving the regular NServiceBus
- configuration of the endpoint so we specify "Logging.MyProductionProfile" on the command line.
- */
-
- public class Endpoint : IConfigureThisEndpoint, AsA_Client {
- public void Customize(BusConfiguration configuration)
- {
- configuration.UsePersistence();
- }
- }
-
- public class MyProductionProfile : Production {}
-
- public class MyProductionLogging : NServiceBus.Hosting.Profiles.IConfigureLoggingForProfile
- {
- public void Configure(IConfigureThisEndpoint specifier)
- {
- Console.WriteLine("I'm going to do my custom logging setup in here using my own profile.");
- }
- }
-}
diff --git a/IntegrationTests/GenericHost/Logging/Logging.csproj b/IntegrationTests/GenericHost/Logging/Logging.csproj
deleted file mode 100644
index 1dc371621dc..00000000000
--- a/IntegrationTests/GenericHost/Logging/Logging.csproj
+++ /dev/null
@@ -1,64 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 9.0.30729
- 2.0
- {15E0163A-315E-4473-9BF3-DD9EA128EBD7}
- Library
- Properties
- Logging
- Logging
- v4.5
- 512
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
- False
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
- False
- ..\..\..\binaries\NServiceBus.Host.exe
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- Program
- $(ProjectDir)$(OutputPath)NServiceBus.Host.exe
- Logging.MyProductionProfile
- false
-
-
\ No newline at end of file
diff --git a/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/App.config b/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/App.config
deleted file mode 100644
index 88101d5902d..00000000000
--- a/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/App.config
+++ /dev/null
@@ -1,14 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/EndpointConfig.cs b/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/EndpointConfig.cs
deleted file mode 100644
index be00feb183d..00000000000
--- a/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/EndpointConfig.cs
+++ /dev/null
@@ -1,28 +0,0 @@
-using System;
-using NServiceBus;
-using NServiceBus.Logging;
-
-namespace LoggingWithConfigurableThreshold
-{
- public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, IWantToRunWhenBusStartsAndStops
- {
- static ILog logger = LogManager.GetLogger("A");
-
- public void Start()
- {
- Console.WriteLine("The WARN threshold has been set in the config file.");
-
- logger.Debug("This should not appear");
- logger.Warn("This should appear");
- }
-
- public void Stop()
- {
- }
-
- public void Customize(BusConfiguration configuration)
- {
- configuration.UsePersistence();
- }
- }
-}
diff --git a/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/LoggingWithConfigurableThreshold.csproj b/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/LoggingWithConfigurableThreshold.csproj
deleted file mode 100644
index a9d30bf8bce..00000000000
--- a/IntegrationTests/GenericHost/LoggingWithConfigurableThreshold/LoggingWithConfigurableThreshold.csproj
+++ /dev/null
@@ -1,67 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 9.0.30729
- 2.0
- {3BF3849F-A0F5-4B9A-BB8F-12D4219F7787}
- Library
- Properties
- LoggingWithConfigurableThreshold
- LoggingWithConfigurableThreshold
- v4.5
- 512
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
- False
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
- False
- ..\..\..\binaries\NServiceBus.Host.exe
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- Program
- $(ProjectDir)$(OutputPath)NServiceBus.Host.exe
- Logging.MyProductionProfile
- false
-
-
\ No newline at end of file
diff --git a/IntegrationTests/MessageMutators/Client/App.config b/IntegrationTests/MessageMutators/Client/App.config
deleted file mode 100644
index 0d7bcd07ba5..00000000000
--- a/IntegrationTests/MessageMutators/Client/App.config
+++ /dev/null
@@ -1,18 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/IntegrationTests/MessageMutators/Client/Client.cs b/IntegrationTests/MessageMutators/Client/Client.cs
deleted file mode 100644
index be878fc80f4..00000000000
--- a/IntegrationTests/MessageMutators/Client/Client.cs
+++ /dev/null
@@ -1,68 +0,0 @@
-using System;
-using Messages;
-using NServiceBus;
-
-namespace Client
-{
- public class EndpointConfig : IConfigureThisEndpoint, AsA_Client
- {
- public void Customize(BusConfiguration configuration)
- {
- configuration.UsePersistence();
- }
- }
-
- public class Runner : IWantToRunWhenBusStartsAndStops
- {
- public IBus Bus { get; set; }
-
- public void Start()
- {
- Console.WriteLine("Press 's' to send a valid message, press 'e' to send a failed message. To exit, 'q'\n");
-
- string cmd;
-
- while ((cmd = Console.ReadKey().Key.ToString().ToLower()) != "q")
- {
- switch (cmd)
- {
- case "s":
- Bus.Send(m =>
- {
- m.ProductId = "XJ128";
- m.ProductName = "Milk";
- m.ListPrice = 4;
- m.SellEndDate = new DateTime(2012, 1, 3);
- // 7MB. MSMQ should throw an exception, but it will not since the buffer will be compressed
- // before it reaches MSMQ.
- m.Image = new byte[1024*1024*7];
- });
- break;
- case "e":
- try
- {
- Bus.Send(m =>
- {
- m.ProductId = "XJ128";
- m.ProductName = "Milk Milk Milk Milk Milk";
- m.ListPrice = 15;
- m.SellEndDate = new DateTime(2011, 1, 3);
- // 7MB. MSMQ should throw an exception, but it will not since the buffer will be compressed
- // before it reaches MSMQ.
- m.Image = new byte[1024*1024*7];
- });
- }
- //Just to allow the sample to keep running.
- catch
- {
- }
- break;
- }
- }
- }
-
- public void Stop()
- {
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/MessageMutators/Client/Client.csproj b/IntegrationTests/MessageMutators/Client/Client.csproj
deleted file mode 100644
index e2abb5ce277..00000000000
--- a/IntegrationTests/MessageMutators/Client/Client.csproj
+++ /dev/null
@@ -1,89 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 9.0.30729
- 2.0
- {9AF57290-9CEE-4934-BDB4-D201F1EABE49}
- Library
- Properties
- Client
- Client
- v4.5
- 512
- publish\
- true
- Disk
- false
- Foreground
- 7
- Days
- false
- false
- true
- 0
- 1.0.0.%2a
- false
- false
- true
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- AllRules.ruleset
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- AllRules.ruleset
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
- False
- ..\..\..\binaries\NServiceBus.Host.exe
-
-
-
- 3.5
-
-
-
-
-
-
-
- {B5B3A66C-7CAD-40A3-ACBC-B82619E62355}
- MessageMutators
-
-
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}
- Messages
-
-
-
-
- Designer
-
-
-
-
- Program
- $(ProjectDir)$(OutputPath)NServiceBus.Host.exe
- false
-
-
\ No newline at end of file
diff --git a/IntegrationTests/MessageMutators/MessageMutator/HookMyMessageMutators.cs b/IntegrationTests/MessageMutators/MessageMutator/HookMyMessageMutators.cs
deleted file mode 100644
index bb97aa99a15..00000000000
--- a/IntegrationTests/MessageMutators/MessageMutator/HookMyMessageMutators.cs
+++ /dev/null
@@ -1,18 +0,0 @@
-using NServiceBus;
-
-namespace MessageMutators
-{
- public class HookMyMessageMutators : INeedInitialization
- {
- public void Customize(BusConfiguration configuration)
- {
- configuration.RegisterComponents(c =>
- {
- c.ConfigureComponent(
- DependencyLifecycle.InstancePerCall);
- c.ConfigureComponent(
- DependencyLifecycle.InstancePerCall);
- });
- }
- }
-}
diff --git a/IntegrationTests/MessageMutators/MessageMutator/MessageMutators.csproj b/IntegrationTests/MessageMutators/MessageMutator/MessageMutators.csproj
deleted file mode 100644
index e26a4bc21ee..00000000000
--- a/IntegrationTests/MessageMutators/MessageMutator/MessageMutators.csproj
+++ /dev/null
@@ -1,59 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 8.0.30703
- 2.0
- {B5B3A66C-7CAD-40A3-ACBC-B82619E62355}
- Library
- Properties
- MessageMutators
- MessageMutators
- v4.5
- 512
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- false
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
- ..\..\..\binaries\NServiceBus.Host.exe
-
-
-
-
-
-
-
-
-
-
-
-
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}
- Messages
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/MessageMutators/MessageMutator/TransportMessageCompressionMutator.cs b/IntegrationTests/MessageMutators/MessageMutator/TransportMessageCompressionMutator.cs
deleted file mode 100644
index cefe4be74c5..00000000000
--- a/IntegrationTests/MessageMutators/MessageMutator/TransportMessageCompressionMutator.cs
+++ /dev/null
@@ -1,44 +0,0 @@
-using System.IO;
-using System.IO.Compression;
-using NServiceBus.Logging;
-using NServiceBus.MessageMutator;
-using NServiceBus;
-using NServiceBus.Unicast.Messages;
-
-namespace MessageMutators
-{
- public class TransportMessageCompressionMutator : IMutateTransportMessages
- {
- private static readonly ILog Logger = LogManager.GetLogger("TransportMessageCompressionMutator");
-
- public void MutateOutgoing(LogicalMessage logicalMessage, TransportMessage transportMessage)
- {
- Logger.Info("transportMessage.Body size before compression: " + transportMessage.Body.Length);
-
- var mStream = new MemoryStream(transportMessage.Body);
- var outStream = new MemoryStream();
-
- using (var tinyStream = new GZipStream(outStream, CompressionMode.Compress))
- {
- mStream.CopyTo(tinyStream);
- }
- // copy the compressed buffer only after the GZipStream is disposed,
- // otherwise, not all the compressed message will be copied.
- transportMessage.Body = outStream.ToArray();
- transportMessage.Headers["IWasCompressed"] = "true";
- Logger.Info("transportMessage.Body size after compression: " + transportMessage.Body.Length);
- }
-
- public void MutateIncoming(TransportMessage transportMessage)
- {
- if (!transportMessage.Headers.ContainsKey("IWasCompressed"))
- return;
- using (var bigStream = new GZipStream(new MemoryStream(transportMessage.Body), CompressionMode.Decompress))
- {
- var bigStreamOut = new MemoryStream();
- bigStream.CopyTo(bigStreamOut);
- transportMessage.Body = bigStreamOut.ToArray();
- }
- }
- }
-}
diff --git a/IntegrationTests/MessageMutators/MessageMutator/ValidationMessageMutator.cs b/IntegrationTests/MessageMutators/MessageMutator/ValidationMessageMutator.cs
deleted file mode 100644
index 536c5845d1e..00000000000
--- a/IntegrationTests/MessageMutators/MessageMutator/ValidationMessageMutator.cs
+++ /dev/null
@@ -1,51 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.ComponentModel.DataAnnotations;
-using System.Text;
-using NServiceBus.Logging;
-using NServiceBus.MessageMutator;
-
-namespace MessageMutators
-{
- public class ValidationMessageMutator : IMessageMutator
- {
- private static readonly ILog Logger = LogManager.GetLogger("ValidationMessageMutator");
-
- public object MutateOutgoing(object message)
- {
- ValidateDataAnnotations(message);
- return message;
- }
-
- public object MutateIncoming(object message)
- {
- ValidateDataAnnotations(message);
- return message;
- }
-
- private static void ValidateDataAnnotations(Object message)
- {
- var context = new ValidationContext(message, null, null);
- var results = new List();
-
- var isValid = Validator.TryValidateObject(message, context, results, true);
-
- if (isValid)
- {
- Logger.Info("Validation succeeded for message: " + message.ToString());
- return;
- }
-
- var errorMessage = new StringBuilder();
- errorMessage.Append(
- string.Format("Validation failed for message {0}, with the following error/s: " + Environment.NewLine,
- message.ToString()));
-
- foreach (var validationResult in results)
- errorMessage.Append(validationResult.ErrorMessage + Environment.NewLine);
-
- Logger.Error(errorMessage.ToString());
- throw new Exception(errorMessage.ToString());
- }
- }
-}
diff --git a/IntegrationTests/MessageMutators/MessageMutators.sln b/IntegrationTests/MessageMutators/MessageMutators.sln
deleted file mode 100644
index ca55ffb0637..00000000000
--- a/IntegrationTests/MessageMutators/MessageMutators.sln
+++ /dev/null
@@ -1,40 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio 2013
-VisualStudioVersion = 12.0.30723.0
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Messages", "Messages\Messages.csproj", "{E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Client", "Client\Client.csproj", "{9AF57290-9CEE-4934-BDB4-D201F1EABE49}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Server", "Server\Server.csproj", "{2FAF88E7-8FC9-4AFA-B265-9085F983C702}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MessageMutators", "MessageMutator\MessageMutators.csproj", "{B5B3A66C-7CAD-40A3-ACBC-B82619E62355}"
-EndProject
-Global
- GlobalSection(SolutionConfigurationPlatforms) = preSolution
- Debug|Any CPU = Debug|Any CPU
- Release|Any CPU = Release|Any CPU
- EndGlobalSection
- GlobalSection(ProjectConfigurationPlatforms) = postSolution
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}.Release|Any CPU.Build.0 = Release|Any CPU
- {9AF57290-9CEE-4934-BDB4-D201F1EABE49}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {9AF57290-9CEE-4934-BDB4-D201F1EABE49}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {9AF57290-9CEE-4934-BDB4-D201F1EABE49}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {9AF57290-9CEE-4934-BDB4-D201F1EABE49}.Release|Any CPU.Build.0 = Release|Any CPU
- {2FAF88E7-8FC9-4AFA-B265-9085F983C702}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {2FAF88E7-8FC9-4AFA-B265-9085F983C702}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {2FAF88E7-8FC9-4AFA-B265-9085F983C702}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {2FAF88E7-8FC9-4AFA-B265-9085F983C702}.Release|Any CPU.Build.0 = Release|Any CPU
- {B5B3A66C-7CAD-40A3-ACBC-B82619E62355}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {B5B3A66C-7CAD-40A3-ACBC-B82619E62355}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {B5B3A66C-7CAD-40A3-ACBC-B82619E62355}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {B5B3A66C-7CAD-40A3-ACBC-B82619E62355}.Release|Any CPU.Build.0 = Release|Any CPU
- EndGlobalSection
- GlobalSection(SolutionProperties) = preSolution
- HideSolutionNode = FALSE
- EndGlobalSection
-EndGlobal
diff --git a/IntegrationTests/MessageMutators/Messages/CreateProductCommand.cs b/IntegrationTests/MessageMutators/Messages/CreateProductCommand.cs
deleted file mode 100644
index 0ad6eeab5dd..00000000000
--- a/IntegrationTests/MessageMutators/Messages/CreateProductCommand.cs
+++ /dev/null
@@ -1,45 +0,0 @@
-using System;
-using System.ComponentModel.DataAnnotations;
-using System.Globalization;
-using NServiceBus;
-
-namespace Messages
-{
- public class CreateProductCommand : ICommand
- {
- [Required]
- public string ProductId { get; set; }
-
- [StringLength(20, ErrorMessage = "The Product Name value cannot exceed 20 characters. ")]
- public string ProductName { get; set; }
-
- [Range(1, 5)]
- public decimal ListPrice { get; set; }
-
- [DateRange(ErrorMessage = "Value for {0} must be between {1} and {2}")]
- public DateTime SellEndDate { get; set; }
-
- public byte[] Image { get; set; }
-
- public override string ToString()
- {
- return string.Format(
- "CreateProductCommand: ProductId={0}, ProductName={1}, ListPrice={2} SellEndDate={3} Image (length)={4}",
- ProductId, ProductName, ListPrice, SellEndDate, (Image == null ? 0: Image.Length));
- }
- }
- ///
- /// Custom Range Attribute for Dates range.
- ///
- class DateRangeAttribute : RangeAttribute
- {
- ///
- /// Constructor
- ///
- public DateRangeAttribute() :
- base(typeof(DateTime), (new DateTime(2012, 1, 1)).ToString(CultureInfo.InvariantCulture), (new DateTime(2012, 5, 1)).ToString(CultureInfo.InvariantCulture))
- {
-
- }
- }
-}
diff --git a/IntegrationTests/MessageMutators/Messages/Messages.csproj b/IntegrationTests/MessageMutators/Messages/Messages.csproj
deleted file mode 100644
index 0580d0e446c..00000000000
--- a/IntegrationTests/MessageMutators/Messages/Messages.csproj
+++ /dev/null
@@ -1,67 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 9.0.30729
- 2.0
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}
- Library
- Properties
- Messages
- Messages
- v4.5
- 512
- publish\
- true
- Disk
- false
- Foreground
- 7
- Days
- false
- false
- true
- 0
- 1.0.0.%2a
- false
- false
- true
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- AllRules.ruleset
- false
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- AllRules.ruleset
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
-
-
- 3.5
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/MessageMutators/Server/App.config b/IntegrationTests/MessageMutators/Server/App.config
deleted file mode 100644
index 6d60b36915b..00000000000
--- a/IntegrationTests/MessageMutators/Server/App.config
+++ /dev/null
@@ -1,9 +0,0 @@
-
-
-
-
-
-
-
-
-
diff --git a/IntegrationTests/MessageMutators/Server/Server.cs b/IntegrationTests/MessageMutators/Server/Server.cs
deleted file mode 100644
index def2c0f6eaa..00000000000
--- a/IntegrationTests/MessageMutators/Server/Server.cs
+++ /dev/null
@@ -1,22 +0,0 @@
-using System;
-using Messages;
-using NServiceBus;
-
-namespace Server
-{
- public class EndpointConfig : IConfigureThisEndpoint, AsA_Server
- {
- public void Customize(BusConfiguration configuration)
- {
- configuration.UsePersistence();
- }
- }
-
- public class Handler : IHandleMessages
- {
- public void Handle(CreateProductCommand createProductCommand)
- {
- Console.WriteLine("Received a CreateProductCommand message: " + createProductCommand);
- }
- }
-}
diff --git a/IntegrationTests/MessageMutators/Server/Server.csproj b/IntegrationTests/MessageMutators/Server/Server.csproj
deleted file mode 100644
index ce3ae59ea98..00000000000
--- a/IntegrationTests/MessageMutators/Server/Server.csproj
+++ /dev/null
@@ -1,83 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 9.0.30729
- 2.0
- {2FAF88E7-8FC9-4AFA-B265-9085F983C702}
- Library
- Properties
- Server
- Server
- v4.5
- 512
- publish\
- true
- Disk
- true
- 0
- 1.0.0.%2a
- false
- false
- true
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- AllRules.ruleset
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- AllRules.ruleset
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
- False
- ..\..\..\binaries\NServiceBus.Host.exe
-
-
-
- 3.5
-
-
-
-
-
-
-
- {B5B3A66C-7CAD-40A3-ACBC-B82619E62355}
- MessageMutators
-
-
- {E62F2DF8-9E8F-4512-9FD9-C97C97AEC15A}
- Messages
-
-
-
-
- Designer
-
-
-
-
- Program
- $(ProjectDir)$(OutputPath)NServiceBus.Host.exe
- false
-
-
\ No newline at end of file
diff --git a/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.Custom/Program.cs b/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.Custom/Program.cs
deleted file mode 100644
index e928f428b6e..00000000000
--- a/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.Custom/Program.cs
+++ /dev/null
@@ -1,25 +0,0 @@
-using System;
-using NServiceBus;
-
-namespace SendOnlyEndpoint.Custom
-{
- public class Program
- {
- static void Main()
- {
- var configuration = new BusConfiguration();
-
- using (var bus = Bus.CreateSendOnly(configuration))
- {
- bus.Send("SendOnlyDestination@someserver",new TestMessage());
- }
-
- Console.WriteLine("Message sent to remote endpoint, you can verify this by looking at the outgoing queues in you msmq MMC-snapin");
- Console.WriteLine("Press any key to exit");
-
- Console.ReadKey();
- }
- }
-
- public class TestMessage : IMessage{}
-}
diff --git a/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.Custom/SendOnlyEndpoint.Custom.csproj b/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.Custom/SendOnlyEndpoint.Custom.csproj
deleted file mode 100644
index 1ebe2b013bb..00000000000
--- a/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.Custom/SendOnlyEndpoint.Custom.csproj
+++ /dev/null
@@ -1,51 +0,0 @@
-
-
-
- Debug
- x86
- 8.0.30703
- 2.0
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}
- Exe
- Properties
- SendOnlyEndpoint.Custom
- SendOnlyEndpoint.Custom
- v4.5
- 512
- ..\
- true
-
-
-
- x86
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- false
-
-
- x86
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.sln b/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.sln
deleted file mode 100644
index 2ccc6ca3907..00000000000
--- a/IntegrationTests/SendOnlyEndpoint/SendOnlyEndpoint.sln
+++ /dev/null
@@ -1,35 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio 2013
-VisualStudioVersion = 12.0.30723.0
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SendOnlyEndpoint.Custom", "SendOnlyEndpoint.Custom\SendOnlyEndpoint.Custom.csproj", "{52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}"
-EndProject
-Global
- GlobalSection(SolutionConfigurationPlatforms) = preSolution
- Debug|Any CPU = Debug|Any CPU
- Debug|Mixed Platforms = Debug|Mixed Platforms
- Debug|x86 = Debug|x86
- Release|Any CPU = Release|Any CPU
- Release|Mixed Platforms = Release|Mixed Platforms
- Release|x86 = Release|x86
- EndGlobalSection
- GlobalSection(ProjectConfigurationPlatforms) = postSolution
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Debug|Any CPU.ActiveCfg = Debug|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Debug|Mixed Platforms.ActiveCfg = Debug|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Debug|Mixed Platforms.Build.0 = Debug|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Debug|x86.ActiveCfg = Debug|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Debug|x86.Build.0 = Debug|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Release|Any CPU.ActiveCfg = Release|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Release|Mixed Platforms.ActiveCfg = Release|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Release|Mixed Platforms.Build.0 = Release|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Release|x86.ActiveCfg = Release|x86
- {52E814AA-CD2D-48F5-AD5C-38D8335DEBF4}.Release|x86.Build.0 = Release|x86
- EndGlobalSection
- GlobalSection(SolutionProperties) = preSolution
- HideSolutionNode = FALSE
- EndGlobalSection
- GlobalSection(ExtensibilityGlobals) = postSolution
- EnterpriseLibraryConfigurationToolBinariesPath = packages\Unity.2.1.505.0\lib\NET35;packages\Unity.Interception.2.1.505.0\lib\NET35
- EndGlobalSection
-EndGlobal
diff --git a/IntegrationTests/TimeoutManager/MyServer/App.config b/IntegrationTests/TimeoutManager/MyServer/App.config
deleted file mode 100644
index 649ee50d75d..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/App.config
+++ /dev/null
@@ -1,17 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/IntegrationTests/TimeoutManager/MyServer/DeferedProcessing/DeferredMessage.cs b/IntegrationTests/TimeoutManager/MyServer/DeferedProcessing/DeferredMessage.cs
deleted file mode 100644
index a121617f9c4..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/DeferedProcessing/DeferredMessage.cs
+++ /dev/null
@@ -1,10 +0,0 @@
-namespace MyServer.DeferedProcessing
-{
- using System;
- using NServiceBus;
-
- public class DeferredMessage:IMessage
- {
- public DateTime ProcessAt { get; set; }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/DeferedProcessing/DeferredMessageHandler.cs b/IntegrationTests/TimeoutManager/MyServer/DeferedProcessing/DeferredMessageHandler.cs
deleted file mode 100644
index 84010f1a5b6..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/DeferedProcessing/DeferredMessageHandler.cs
+++ /dev/null
@@ -1,28 +0,0 @@
-namespace MyServer.DeferedProcessing
-{
- using System;
- using NServiceBus;
-
- public class DeferredMessageHandler : IHandleMessages
- {
- public IBus Bus { get; set; }
-
- public void Handle(DeferredMessage message)
- {
- if (!Bus.CurrentMessageContext.Headers.ContainsKey(Headers.IsDeferredMessage))
- {
- LogMessage("Message will be processed at " + message.ProcessAt.ToLongTimeString());
-
- Bus.Defer(message.ProcessAt, message);
- return;
- }
-
- LogMessage("Deferred message processed");
- }
-
- static void LogMessage(string message)
- {
- Console.WriteLine("{0} - {1}", DateTime.Now.ToLongTimeString(), message);
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/EndpointConfig.cs b/IntegrationTests/TimeoutManager/MyServer/EndpointConfig.cs
deleted file mode 100644
index 6ff8edc427d..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/EndpointConfig.cs
+++ /dev/null
@@ -1,48 +0,0 @@
-using NServiceBus.Persistence;
-using NServiceBus.Persistence.Legacy;
-using NServiceBus.Unicast.Messages;
-
-namespace MyServer
-{
- using NServiceBus;
- using NServiceBus.MessageMutator;
-
- public class EndpointConfig : IConfigureThisEndpoint, AsA_Server
- {
- public void Customize(BusConfiguration configuration)
- {
- configuration.UsePersistence();
- configuration.UsePersistence().For(Storage.Subscriptions);
- }
- }
-
- ///
- /// This mutator makes sure that the tenant id is propagated to all outgoing messages
- ///
- public class TenantPropagatingMutator : IMutateOutgoingTransportMessages, INeedInitialization
- {
- public IBus Bus { get; set; }
-
-
- public void MutateOutgoing(LogicalMessage logicalMessage, TransportMessage transportMessage)
- {
- if (Bus.CurrentMessageContext == null)
- {
- return;
- }
-
- if (!Bus.CurrentMessageContext.Headers.ContainsKey("tenant"))
- {
- return;
- }
-
- transportMessage.Headers["tenant"] = Bus.CurrentMessageContext.Headers["tenant"];
- }
-
- public void Customize(BusConfiguration configuration)
- {
- configuration.RegisterComponents(c => c.ConfigureComponent(
- DependencyLifecycle.InstancePerCall));
- }
- }
-}
diff --git a/IntegrationTests/TimeoutManager/MyServer/MyServer.csproj b/IntegrationTests/TimeoutManager/MyServer/MyServer.csproj
deleted file mode 100644
index e0f40fe19f6..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/MyServer.csproj
+++ /dev/null
@@ -1,76 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 8.0.30703
- 2.0
- {5B4F9AC7-B891-4D6A-8804-12B6AF89BE53}
- Library
- Properties
- MyServer
- MyServer
- v4.5
- 512
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- true
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
- ..\..\..\binaries\NServiceBus.Host.exe
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- Designer
-
-
-
-
- Program
- $(ProjectDir)$(OutputPath)NServiceBus.Host.exe
- NServiceBus.Integration
- true
- false
-
-
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/PerformanceTest/PerformanceTestMessage.cs b/IntegrationTests/TimeoutManager/MyServer/PerformanceTest/PerformanceTestMessage.cs
deleted file mode 100644
index 202bb433f87..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/PerformanceTest/PerformanceTestMessage.cs
+++ /dev/null
@@ -1,8 +0,0 @@
-namespace MyServer.PerformanceTest
-{
- using NServiceBus;
-
- public class PerformanceTestMessage:IMessage
- {
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/PerformanceTest/PerformanceTestMessageHandler.cs b/IntegrationTests/TimeoutManager/MyServer/PerformanceTest/PerformanceTestMessageHandler.cs
deleted file mode 100644
index 7175fc296d6..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/PerformanceTest/PerformanceTestMessageHandler.cs
+++ /dev/null
@@ -1,33 +0,0 @@
-namespace MyServer.PerformanceTest
-{
- using System;
- using System.Collections.Concurrent;
- using NServiceBus;
-
- public class PerformanceTestMessageHandler : IHandleMessages
- {
- public static ConcurrentBag receivedMessages = new ConcurrentBag();
-
- public static int NumExpectedMessages;
- public static DateTime TimeStarted;
- public static DateTime TimeEnded;
-
- public IBus Bus { get; set; }
-
- public void Handle(PerformanceTestMessage message)
- {
- receivedMessages.Add(Bus.CurrentMessageContext.Id);
-
- Console.WriteLine("Message {0}({1})", receivedMessages.Count, NumExpectedMessages);
-
- if (NumExpectedMessages == receivedMessages.Count)
- {
- TimeEnded = DateTime.UtcNow;
- Console.WriteLine("Test finished, total time: {0}", TimeEnded - TimeStarted);
- }
-
- if (receivedMessages.Count > NumExpectedMessages && NumExpectedMessages > 0)
- throw new InvalidOperationException("More messages than expected received");
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Saga/MyTimeOutState.cs b/IntegrationTests/TimeoutManager/MyServer/Saga/MyTimeOutState.cs
deleted file mode 100644
index 145b2543afd..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Saga/MyTimeOutState.cs
+++ /dev/null
@@ -1,7 +0,0 @@
-namespace MyServer.Saga
-{
- public class MyTimeOutState
- {
- public int SomeValue { get; set; }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Saga/SimpleSaga.cs b/IntegrationTests/TimeoutManager/MyServer/Saga/SimpleSaga.cs
deleted file mode 100644
index 7a85765a12c..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Saga/SimpleSaga.cs
+++ /dev/null
@@ -1,36 +0,0 @@
-namespace MyServer.Saga
-{
- using System;
- using NServiceBus.Saga;
-
- public class SimpleSaga:Saga,
- IAmStartedByMessages,
- IHandleTimeouts
- {
- public void Handle(StartSagaMessage message)
- {
- Data.OrderId = message.OrderId;
- var someState = new Random().Next(10);
-
- RequestTimeout(TimeSpan.FromSeconds(10), t => t.SomeValue = someState);
- }
-
- protected override void ConfigureHowToFindSaga(SagaPropertyMapper mapper)
- {
- mapper.ConfigureMapping(s => s.OrderId).ToSaga(m => m.OrderId);
- }
-
- void LogMessage(string message)
- {
- Console.WriteLine("{0} - {1} - SagaId:{2}", DateTime.Now.ToLongTimeString(), message, Data.Id);
- }
-
- public void Timeout(MyTimeOutState state)
- {
- LogMessage("Timeout fired, with state: " + state.SomeValue);
-
- LogMessage("Marking the saga as complete, be aware that this will remove the document from the storage");
- MarkAsComplete();
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Saga/SimpleSagaData.cs b/IntegrationTests/TimeoutManager/MyServer/Saga/SimpleSagaData.cs
deleted file mode 100644
index 0fe74ad51f6..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Saga/SimpleSagaData.cs
+++ /dev/null
@@ -1,15 +0,0 @@
-namespace MyServer.Saga
-{
- using System;
- using NServiceBus.Saga;
-
- public class SimpleSagaData : IContainSagaData
- {
- public Guid Id { get; set; }
- public string Originator { get; set; }
- public string OriginalMessageId { get; set; }
-
- [Unique]
- public Guid OrderId { get; set; }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Saga/StartSagaMessage.cs b/IntegrationTests/TimeoutManager/MyServer/Saga/StartSagaMessage.cs
deleted file mode 100644
index e579aeb1181..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Saga/StartSagaMessage.cs
+++ /dev/null
@@ -1,10 +0,0 @@
-namespace MyServer.Saga
-{
- using System;
- using NServiceBus;
-
- public class StartSagaMessage:IMessage
- {
- public Guid OrderId { get; set; }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATask.cs b/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATask.cs
deleted file mode 100644
index 7bb7f511b10..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATask.cs
+++ /dev/null
@@ -1,12 +0,0 @@
-using NServiceBus;
-
-namespace MyServer.Scheduling
-{
- public class ScheduleATask : IMessage
- {
- }
-
- public class ScheduledTaskExecuted : IMessage
- {
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATaskHandler.cs b/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATaskHandler.cs
deleted file mode 100644
index c0a49662168..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATaskHandler.cs
+++ /dev/null
@@ -1,23 +0,0 @@
-using System;
-using NServiceBus;
-
-namespace MyServer.Scheduling
-{
- public class ScheduleATaskHandler : IHandleMessages
- {
- private readonly IBus bus;
-
- public Schedule Schedule { get; set; }
-
- public ScheduleATaskHandler(IBus bus)
- {
- this.bus = bus;
- }
-
- public void Handle(ScheduleATask message)
- {
- Console.WriteLine("Scheduling a task to be executed every 1 minute");
- Schedule.Every(TimeSpan.FromMinutes(1),() => bus.SendLocal(new ScheduledTaskExecuted()));
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATaskToRunAtStartUp.cs b/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATaskToRunAtStartUp.cs
deleted file mode 100644
index 2b6a882d1b7..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduleATaskToRunAtStartUp.cs
+++ /dev/null
@@ -1,26 +0,0 @@
-using System;
-using System.Threading;
-using NServiceBus;
-
-namespace MyServer.Scheduling
-{
- public class ScheduleATaskToRunAtStartUp : IWantToRunWhenBusStartsAndStops
- {
- public Schedule Schedule { get; set; }
- public void Start()
- {
- Schedule.Every(TimeSpan.FromMinutes(5),() => Console.WriteLine("This task was schduled when the host started"));
-
- Schedule.Every(TimeSpan.FromMinutes(3),"Task with specified name",() =>
- {
- Thread.Sleep(60 * 1000);
- Console.WriteLine("This task was schduled when the host started and given a name");
- });
- }
-
- public void Stop()
- {
- throw new NotImplementedException();
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduledTaskExecutedHandler.cs b/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduledTaskExecutedHandler.cs
deleted file mode 100644
index d8f94cead54..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Scheduling/ScheduledTaskExecutedHandler.cs
+++ /dev/null
@@ -1,13 +0,0 @@
-using System;
-using NServiceBus;
-
-namespace MyServer.Scheduling
-{
- public class ScheduledTaskExecutedHandler : IHandleMessages
- {
- public void Handle(ScheduledTaskExecuted message)
- {
- Console.WriteLine("ScheduledTaskExecuted handler executed");
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/MyServer/Starter.cs b/IntegrationTests/TimeoutManager/MyServer/Starter.cs
deleted file mode 100644
index b296089675b..00000000000
--- a/IntegrationTests/TimeoutManager/MyServer/Starter.cs
+++ /dev/null
@@ -1,96 +0,0 @@
-using MyServer.Scheduling;
-
-namespace MyServer
-{
- using System;
- using System.Collections.Concurrent;
- using DeferedProcessing;
- using NServiceBus;
- using PerformanceTest;
- using Saga;
-
- class Starter : IWantToRunWhenBusStartsAndStops
- {
- public IBus Bus { get; set; }
-
- public void Start()
- {
- Console.WriteLine("Press 'S' to start the saga");
- Console.WriteLine("Press 'T' to start the saga in multi tenant mode");
- Console.WriteLine("Press 'D' to defer a message 10 seconds");
- Console.WriteLine("Press 'R' to schedule a task");
- Console.WriteLine("To exit, press Ctrl + C");
-
- string cmd;
-
- while ((cmd = Console.ReadKey().Key.ToString().ToLower()) != "q")
- {
- switch (cmd)
- {
- case "s":
- StartSaga();
- break;
-
- case "t":
- //make sure that the database exists!
- StartSaga("MyApp.Tenants.Acme");
- break;
-
- case "d":
- DeferMessage();
- break;
-
- case "r":
- ScheduleTask();
- break;
- case "p":
- PerformanceTest();
- break;
- }
- }
- }
-
- void PerformanceTest()
- {
- var total = 40000;
- PerformanceTestMessageHandler.receivedMessages = new ConcurrentBag();
- PerformanceTestMessageHandler.NumExpectedMessages = total;
- PerformanceTestMessageHandler.TimeStarted = DateTime.UtcNow;
- System.Threading.Tasks.Parallel.For(0, total, _ => Bus.Defer(TimeSpan.FromMinutes(20), new PerformanceTestMessage()));
- }
-
- void DeferMessage()
- {
- Console.WriteLine("{0} - {1}", DateTime.Now.ToLongTimeString(), "Sending a message to be processed at a later time");
- Bus.SendLocal(new DeferredMessage
- {
- ProcessAt = DateTime.Now.AddSeconds(10)
- });
- }
-
- void StartSaga(string tenant = "")
- {
- var message = new StartSagaMessage
- {
- OrderId = Guid.NewGuid()
- };
- if (!string.IsNullOrEmpty(tenant))
- {
- Bus.SetMessageHeader(message, "tenant", tenant);
- }
-
- Bus.SendLocal(message);
- Console.WriteLine("{0} - {1}", DateTime.Now.ToLongTimeString(), "Saga start message sent");
- }
-
- void ScheduleTask()
- {
- // The actual scheduling is done in ScheduleATaskHandler
- Bus.SendLocal(new ScheduleATask());
- }
-
- public void Stop()
- {
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/TimeoutManager/TimeoutManager.sln b/IntegrationTests/TimeoutManager/TimeoutManager.sln
deleted file mode 100644
index 043a15ed266..00000000000
--- a/IntegrationTests/TimeoutManager/TimeoutManager.sln
+++ /dev/null
@@ -1,22 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio 2013
-VisualStudioVersion = 12.0.30723.0
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyServer", "MyServer\MyServer.csproj", "{5B4F9AC7-B891-4D6A-8804-12B6AF89BE53}"
-EndProject
-Global
- GlobalSection(SolutionConfigurationPlatforms) = preSolution
- Debug|Any CPU = Debug|Any CPU
- Release|Any CPU = Release|Any CPU
- EndGlobalSection
- GlobalSection(ProjectConfigurationPlatforms) = postSolution
- {5B4F9AC7-B891-4D6A-8804-12B6AF89BE53}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
- {5B4F9AC7-B891-4D6A-8804-12B6AF89BE53}.Debug|Any CPU.Build.0 = Debug|Any CPU
- {5B4F9AC7-B891-4D6A-8804-12B6AF89BE53}.Release|Any CPU.ActiveCfg = Release|Any CPU
- {5B4F9AC7-B891-4D6A-8804-12B6AF89BE53}.Release|Any CPU.Build.0 = Release|Any CPU
- EndGlobalSection
- GlobalSection(SolutionProperties) = preSolution
- HideSolutionNode = FALSE
- EndGlobalSection
-EndGlobal
diff --git a/IntegrationTests/Unobtrusive/Client/App.config b/IntegrationTests/Unobtrusive/Client/App.config
deleted file mode 100644
index d75df73b213..00000000000
--- a/IntegrationTests/Unobtrusive/Client/App.config
+++ /dev/null
@@ -1,26 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Client/Client.csproj b/IntegrationTests/Unobtrusive/Client/Client.csproj
deleted file mode 100644
index d2eff9e7dde..00000000000
--- a/IntegrationTests/Unobtrusive/Client/Client.csproj
+++ /dev/null
@@ -1,83 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 8.0.30703
- 2.0
- {476D0A88-E281-4BC8-9617-93E53C1F9FE6}
- Library
- Properties
- Client
- Client
- v4.5
- 512
- ..\..\Unobtrusive\
- true
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
- ..\..\..\binaries\NServiceBus.Host.exe
-
-
-
-
-
-
-
-
-
-
-
-
- Designer
-
-
-
-
- {5AD5EAEF-AF56-49B7-A15D-C0F71780049F}
- Commands
-
-
- {6F35A2BC-639A-429D-8A40-35784600E956}
- Events
-
-
- {DD0DC12D-D6DF-47C0-B75A-AEC351164196}
- Messages
-
-
- {fa4a7645-09b1-47a7-962d-6d3da27f0bce}
- MyConventions
-
-
-
-
- Program
- $(ProjectDir)$(OutputPath)NServiceBus.Host.exe
- NServiceBus.Integration
- false
-
-
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Client/CommandSender.cs b/IntegrationTests/Unobtrusive/Client/CommandSender.cs
deleted file mode 100644
index d43a2af6217..00000000000
--- a/IntegrationTests/Unobtrusive/Client/CommandSender.cs
+++ /dev/null
@@ -1,134 +0,0 @@
-namespace Client
-{
- using System;
- using Commands;
- using Messages;
- using NServiceBus;
-
- public class CommandSender : IWantToRunWhenBusStartsAndStops
- {
- public IBus Bus { get; set; }
-
- public void Start()
- {
- Console.WriteLine("Press 'C' to send a command");
- Console.WriteLine("Press 'R' to send a request");
- Console.WriteLine("Press 'S' to start the saga");
- Console.WriteLine("Press 'E' to send a message that is marked as Express");
- Console.WriteLine("Press 'D' to send a large message that is marked to be sent using Data Bus");
- Console.WriteLine("Press 'X' to send a message that is marked with expiration time.");
- Console.WriteLine("To exit, press Ctrl + C");
-
- while (true)
- {
- var cmd = Console.ReadKey().Key.ToString().ToLower();
- switch (cmd)
- {
- case "c":
- SendCommand();
- break;
-
- case "r":
- SendRequest();
- break;
-
- case "s":
- StartSaga();
- break;
-
- case "e":
- Express();
- break;
-
- case "d":
- Data();
- break;
-
- case "x":
- Expiration();
- break;
- }
- }
- }
-
- ///
- /// Shut down server before sending this message, after 30 seconds, the message will be moved to Transactional dead-letter messages queue.
- ///
- private void Expiration()
- {
- Bus.Send(m => m.RequestId = Guid.NewGuid());
- Console.WriteLine("message with expiration was sent");
- }
-
- private void Data()
- {
- var requestId = Guid.NewGuid();
-
- Bus.Send(m =>
- {
- m.RequestId = requestId;
- m.LargeDataBus = new byte[1024 * 1024 * 5];
- });
-
- Console.WriteLine("Request sent id: " + requestId);
- }
-
- private void Express()
- {
- var requestId = Guid.NewGuid();
-
- Bus.Send(m =>
- {
- m.RequestId = requestId;
- });
-
- Console.WriteLine("Request sent id: " + requestId);
- }
-
- void StartSaga(string tennant = "")
- {
- var message = new StartSagaMessage
- {
- OrderId = Guid.NewGuid()
- };
- if (!string.IsNullOrEmpty(tennant))
- {
- Bus.SetMessageHeader(message, "tennant", tennant);
- }
-
- Bus.Send(message);
- Console.WriteLine("{0} - {1}", DateTime.Now.ToLongTimeString(), "Saga start message sent");
- }
-
- void SendRequest()
- {
- var requestId = Guid.NewGuid();
-
- Bus.Send(m =>
- {
- m.RequestId = requestId;
- });
-
- Console.WriteLine("Request sent id: " + requestId);
- }
-
- void SendCommand()
- {
- var commandId = Guid.NewGuid();
-
- Bus.Send(m =>
- {
- m.CommandId = commandId;
- m.EncryptedString = "Some sensitive information";
- })
- .Register(outcome => Console.WriteLine("Server returned status: " + outcome));
-
- Console.WriteLine("Command sent id: " + commandId);
-
- }
-
- public void Stop()
- {
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Client/EndpointConfig.cs b/IntegrationTests/Unobtrusive/Client/EndpointConfig.cs
deleted file mode 100644
index 6ea58cdcbe7..00000000000
--- a/IntegrationTests/Unobtrusive/Client/EndpointConfig.cs
+++ /dev/null
@@ -1,15 +0,0 @@
-namespace Client
-{
- using NServiceBus;
-
- public class EndpointConfig : IConfigureThisEndpoint, AsA_Client
- {
- public void Customize(BusConfiguration configuration)
- {
- configuration.UsePersistence();
- configuration.FileShareDataBus(@"..\..\..\DataBusShare\");
- configuration.RijndaelEncryptionService();
- }
- }
-
-}
diff --git a/IntegrationTests/Unobtrusive/Client/MyEventHandler.cs b/IntegrationTests/Unobtrusive/Client/MyEventHandler.cs
deleted file mode 100644
index 7385a785942..00000000000
--- a/IntegrationTests/Unobtrusive/Client/MyEventHandler.cs
+++ /dev/null
@@ -1,14 +0,0 @@
-namespace Client
-{
- using System;
- using Events;
- using NServiceBus;
-
- public class MyEventHandler : IHandleMessages
- {
- public void Handle(IMyEvent message)
- {
- Console.WriteLine("IMyEvent received from server with id:" + message.EventId);
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Client/ResponseHandler.cs b/IntegrationTests/Unobtrusive/Client/ResponseHandler.cs
deleted file mode 100644
index 678df219628..00000000000
--- a/IntegrationTests/Unobtrusive/Client/ResponseHandler.cs
+++ /dev/null
@@ -1,14 +0,0 @@
-namespace Client
-{
- using System;
- using Messages;
- using NServiceBus;
-
- public class ResponseHandler : IHandleMessages
- {
- public void Handle(Response message)
- {
- Console.WriteLine("Response received from server for request with id:" + message.ResponseId);
- }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Commands/CommandStatus.cs b/IntegrationTests/Unobtrusive/Commands/CommandStatus.cs
deleted file mode 100644
index 2b1383d8b89..00000000000
--- a/IntegrationTests/Unobtrusive/Commands/CommandStatus.cs
+++ /dev/null
@@ -1,7 +0,0 @@
-namespace Commands
-{
- public enum CommandStatus
- {
- Ok
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Commands/Commands.csproj b/IntegrationTests/Unobtrusive/Commands/Commands.csproj
deleted file mode 100644
index 23e0967853a..00000000000
--- a/IntegrationTests/Unobtrusive/Commands/Commands.csproj
+++ /dev/null
@@ -1,43 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 8.0.30703
- 2.0
- {5AD5EAEF-AF56-49B7-A15D-C0F71780049F}
- Library
- Properties
- Commands
- Commands
- v4.0
- 512
- ..\..\Unobtrusive\
- true
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Commands/MyCommand.cs b/IntegrationTests/Unobtrusive/Commands/MyCommand.cs
deleted file mode 100644
index 372156b6bc9..00000000000
--- a/IntegrationTests/Unobtrusive/Commands/MyCommand.cs
+++ /dev/null
@@ -1,10 +0,0 @@
-namespace Commands
-{
- using System;
-
- public class MyCommand
- {
- public Guid CommandId { get; set; }
- public string EncryptedString { get; set; }
- }
-}
diff --git a/IntegrationTests/Unobtrusive/DataBusShare/2012-12-06_08/2efd0760-d27e-41e0-9b9b-a2a7aa178fd4 b/IntegrationTests/Unobtrusive/DataBusShare/2012-12-06_08/2efd0760-d27e-41e0-9b9b-a2a7aa178fd4
deleted file mode 100644
index d73518d2311..00000000000
Binary files a/IntegrationTests/Unobtrusive/DataBusShare/2012-12-06_08/2efd0760-d27e-41e0-9b9b-a2a7aa178fd4 and /dev/null differ
diff --git a/IntegrationTests/Unobtrusive/Events/Events.csproj b/IntegrationTests/Unobtrusive/Events/Events.csproj
deleted file mode 100644
index 17296fea619..00000000000
--- a/IntegrationTests/Unobtrusive/Events/Events.csproj
+++ /dev/null
@@ -1,45 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 8.0.30703
- 2.0
- {6F35A2BC-639A-429D-8A40-35784600E956}
- Library
- Properties
- Events
- Events
- v4.5
- 512
- ..\..\Unobtrusive\
- true
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- false
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Events/IMyEvent.cs b/IntegrationTests/Unobtrusive/Events/IMyEvent.cs
deleted file mode 100644
index 75cf9f43106..00000000000
--- a/IntegrationTests/Unobtrusive/Events/IMyEvent.cs
+++ /dev/null
@@ -1,9 +0,0 @@
-namespace Events
-{
- using System;
-
- public interface IMyEvent
- {
- Guid EventId { get; set; }
- }
-}
diff --git a/IntegrationTests/Unobtrusive/Messages/DeferredMessage.cs b/IntegrationTests/Unobtrusive/Messages/DeferredMessage.cs
deleted file mode 100644
index 76701acd4e1..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/DeferredMessage.cs
+++ /dev/null
@@ -1,7 +0,0 @@
-namespace Messages
-{
- public class DeferredMessage
- {
-
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Messages/LargeMessage.cs b/IntegrationTests/Unobtrusive/Messages/LargeMessage.cs
deleted file mode 100644
index d61ff804b0b..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/LargeMessage.cs
+++ /dev/null
@@ -1,10 +0,0 @@
-namespace Messages
-{
- using System;
-
- public class LargeMessage
- {
- public Guid RequestId { get; set; }
- public byte[] LargeDataBus { get; set; }
- }
-}
diff --git a/IntegrationTests/Unobtrusive/Messages/MessageThatExpires.cs b/IntegrationTests/Unobtrusive/Messages/MessageThatExpires.cs
deleted file mode 100644
index 00697bbc81e..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/MessageThatExpires.cs
+++ /dev/null
@@ -1,9 +0,0 @@
-namespace Messages
-{
- using System;
-
- public class MessageThatExpires
- {
- public Guid RequestId { get; set; }
- }
-}
diff --git a/IntegrationTests/Unobtrusive/Messages/Messages.csproj b/IntegrationTests/Unobtrusive/Messages/Messages.csproj
deleted file mode 100644
index 899d9fba103..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/Messages.csproj
+++ /dev/null
@@ -1,51 +0,0 @@
-
-
-
- Debug
- AnyCPU
- 8.0.30703
- 2.0
- {DD0DC12D-D6DF-47C0-B75A-AEC351164196}
- Library
- Properties
- Messages
- Messages
- v4.5
- 512
- ..\..\Unobtrusive\
- true
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- false
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Messages/Request.cs b/IntegrationTests/Unobtrusive/Messages/Request.cs
deleted file mode 100644
index 4525f31b2f6..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/Request.cs
+++ /dev/null
@@ -1,9 +0,0 @@
-namespace Messages
-{
- using System;
-
- public class Request
- {
- public Guid RequestId { get; set; }
- }
-}
diff --git a/IntegrationTests/Unobtrusive/Messages/RequestExpress.cs b/IntegrationTests/Unobtrusive/Messages/RequestExpress.cs
deleted file mode 100644
index 655d84dbc94..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/RequestExpress.cs
+++ /dev/null
@@ -1,9 +0,0 @@
-namespace Messages
-{
- using System;
-
- public class RequestExpress
- {
- public Guid RequestId { get; set; }
- }
-}
diff --git a/IntegrationTests/Unobtrusive/Messages/Response.cs b/IntegrationTests/Unobtrusive/Messages/Response.cs
deleted file mode 100644
index bf0aa1b026a..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/Response.cs
+++ /dev/null
@@ -1,9 +0,0 @@
-namespace Messages
-{
- using System;
-
- public class Response
- {
- public Guid ResponseId { get; set; }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Messages/StartSagaMessage.cs b/IntegrationTests/Unobtrusive/Messages/StartSagaMessage.cs
deleted file mode 100644
index 639ca576d05..00000000000
--- a/IntegrationTests/Unobtrusive/Messages/StartSagaMessage.cs
+++ /dev/null
@@ -1,9 +0,0 @@
-namespace Messages
-{
- using System;
-
- public class StartSagaMessage
- {
- public Guid OrderId { get; set; }
- }
-}
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/MyConventions/MessageConventions.cs b/IntegrationTests/Unobtrusive/MyConventions/MessageConventions.cs
deleted file mode 100644
index b201a1555ef..00000000000
--- a/IntegrationTests/Unobtrusive/MyConventions/MessageConventions.cs
+++ /dev/null
@@ -1,23 +0,0 @@
-using System;
-
-namespace MyConventions
-{
- using NServiceBus;
-
- public class MessageConventions : INeedInitialization
- {
- public void Customize(BusConfiguration configuration)
- {
- configuration.Conventions().DefiningCommandsAs(t => t.Namespace != null && t.Namespace.EndsWith("Commands"))
- .DefiningEventsAs(t => t.Namespace != null && t.Namespace.EndsWith("Events"))
- .DefiningMessagesAs(t => t.Namespace == "Messages")
- .DefiningEncryptedPropertiesAs(p => p.Name.StartsWith("Encrypted"))
- .DefiningDataBusPropertiesAs(p => p.Name.EndsWith("DataBus"))
- .DefiningExpressMessagesAs(t => t.Name.EndsWith("Express"))
- .DefiningTimeToBeReceivedAs(t => t.Name.EndsWith("Expires")
- ? TimeSpan.FromSeconds(30)
- : TimeSpan.MaxValue
- );
- }
- }
-}
diff --git a/IntegrationTests/Unobtrusive/MyConventions/MyConventions.csproj b/IntegrationTests/Unobtrusive/MyConventions/MyConventions.csproj
deleted file mode 100644
index e1259c28852..00000000000
--- a/IntegrationTests/Unobtrusive/MyConventions/MyConventions.csproj
+++ /dev/null
@@ -1,51 +0,0 @@
-
-
-
-
- Debug
- AnyCPU
- {FA4A7645-09B1-47A7-962D-6D3DA27F0BCE}
- Library
- Properties
- MyConventions
- MyConventions
- v4.5
- 512
-
-
-
- true
- full
- false
- bin\Debug\
- DEBUG;TRACE
- prompt
- 4
- false
-
-
- pdbonly
- true
- bin\Release\
- TRACE
- prompt
- 4
- false
-
-
-
- ..\..\..\binaries\NServiceBus.Core.dll
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Server/App.config b/IntegrationTests/Unobtrusive/Server/App.config
deleted file mode 100644
index a1874ea144f..00000000000
--- a/IntegrationTests/Unobtrusive/Server/App.config
+++ /dev/null
@@ -1,11 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/IntegrationTests/Unobtrusive/Server/CatchAllMessageHandler.cs b/IntegrationTests/Unobtrusive/Server/CatchAllMessageHandler.cs
deleted file mode 100644
index a6855662a88..00000000000
--- a/IntegrationTests/Unobtrusive/Server/CatchAllMessageHandler.cs
+++ /dev/null
@@ -1,13 +0,0 @@
-namespace Server
-{
- using System;
- using NServiceBus;
-
- public class CatchAllMessageHandler : IHandleMessages