Skip to content

Commit 5ef32ba

Browse files
committed
Merge branch 'release-1.3.0'
2 parents cb6fdbe + 3b29fd9 commit 5ef32ba

File tree

56 files changed

+1175
-233
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

56 files changed

+1175
-233
lines changed

.gitattributes

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,8 @@
2222
*.pptx -text -diff
2323
*.xap -text -diff
2424
*.ico -text -diff
25+
*.ttf -text -diff
26+
*.otf -text -diff
2527

2628
*.cs text diff=csharp
2729
*.config text diff=csharp
@@ -69,3 +71,6 @@
6971
*.snk -text -diff
7072
*.cub -text -diff
7173
*.wixlib -text -diff
74+
75+
76+
*.approved.* binary

.gitignore

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,5 +35,3 @@ _NCrunch_NServiceBus/*
3535
logs
3636
run-git.cmd
3737
src/Chocolatey/Build/*
38-
App_Packages
39-
octopus/Build/*

src/ServiceControl.AcceptanceTests/App.config

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,11 @@
2020
</dependentAssembly>
2121
<dependentAssembly>
2222
<assemblyIdentity name="NServiceBus.Core" publicKeyToken="9fc386479f8a226c" culture="neutral" />
23-
<bindingRedirect oldVersion="0.0.0.0-4.6.0.0" newVersion="4.6.0.0" />
23+
<bindingRedirect oldVersion="0.0.0.0-4.6.5.0" newVersion="4.6.5.0" />
2424
</dependentAssembly>
2525
<dependentAssembly>
2626
<assemblyIdentity name="NServiceBus" publicKeyToken="9fc386479f8a226c" culture="neutral" />
27-
<bindingRedirect oldVersion="0.0.0.0-4.6.0.0" newVersion="4.6.0.0" />
27+
<bindingRedirect oldVersion="0.0.0.0-4.6.5.0" newVersion="4.6.5.0" />
2828
</dependentAssembly>
2929
<dependentAssembly>
3030
<assemblyIdentity name="Raven.Client.Lightweight" publicKeyToken="37f41c7f99471593" culture="neutral" />

src/ServiceControl.AcceptanceTests/Contexts/ConfigureExtensions.cs

Lines changed: 0 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,6 @@
33
using System;
44
using System.Collections.Generic;
55
using NServiceBus;
6-
using NServiceBus.Serializers.Binary;
7-
using NServiceBus.Serializers.Json;
8-
using NServiceBus.Serializers.XML;
96
using TransportIntegration;
107

118
public static class ConfigureExtensions
@@ -30,44 +27,6 @@ public static Configure DefineTransport(this Configure config, ITransportIntegra
3027
return config.UseTransport(transport.Type, () => transport.ConnectionString);
3128
}
3229

33-
public static Configure DefineSerializer(this Configure config, string serializer)
34-
{
35-
if (string.IsNullOrEmpty(serializer))
36-
{
37-
Configure.Serialization.Xml();
38-
return config;
39-
}
40-
41-
var type = Type.GetType(serializer);
42-
43-
if (type == typeof(XmlMessageSerializer))
44-
{
45-
Configure.Serialization.Xml();
46-
return config;
47-
}
48-
49-
50-
if (type == typeof(JsonMessageSerializer))
51-
{
52-
Configure.Serialization.Json();
53-
return config;
54-
}
55-
56-
if (type == typeof(BsonMessageSerializer))
57-
{
58-
Configure.Serialization.Bson();
59-
return config;
60-
}
61-
62-
if (type == typeof(BinaryMessageSerializer))
63-
{
64-
Configure.Serialization.Binary();
65-
return config;
66-
}
67-
68-
throw new InvalidOperationException("Unknown serializer:" + serializer);
69-
}
70-
7130
public static Configure DefineBuilder(this Configure config, string builder)
7231
{
7332
if (string.IsNullOrEmpty(builder))

src/ServiceControl.AcceptanceTests/Contexts/DefaultServer.cs

Lines changed: 17 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,11 @@ public virtual void AddMoreConfig()
3131

3232
}
3333

34+
public virtual void SetSerializer(Configure configure)
35+
{
36+
//NOOP Default is XML serializer
37+
}
38+
3439
public Configure GetConfiguration(RunDescriptor runDescriptor, EndpointConfiguration endpointConfiguration,
3540
IConfigurationSource configSource)
3641
{
@@ -47,10 +52,14 @@ public Configure GetConfiguration(RunDescriptor runDescriptor, EndpointConfigura
4752
AddMoreConfig();
4853

4954
var config = Configure.With(types)
55+
.DefiningEventsAs(t => typeof(IEvent).IsAssignableFrom(t) || IsExternalContract(t))
5056
.DefineEndpointName(endpointConfiguration.EndpointName)
5157
.CustomConfigurationSource(configSource)
52-
.DefineBuilder(settings.GetOrNull("Builder"))
53-
.DefineSerializer(settings.GetOrNull("Serializer"))
58+
.DefineBuilder(settings.GetOrNull("Builder"));
59+
60+
SetSerializer(config);
61+
62+
config
5463
.DefineTransport(transportToUse)
5564
.InMemorySagaPersister();
5665

@@ -71,6 +80,12 @@ public Configure GetConfiguration(RunDescriptor runDescriptor, EndpointConfigura
7180
return config.UnicastBus();
7281
}
7382

83+
static bool IsExternalContract(Type t)
84+
{
85+
return t.Namespace != null && t.Namespace.StartsWith("ServiceControl.Contracts");
86+
}
87+
88+
7489
static void SetupLogging(EndpointConfiguration endpointConfiguration)
7590
{
7691
var logDir = ".\\logfiles\\";
Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
namespace ServiceBus.Management.AcceptanceTests.Contexts
2+
{
3+
using System.IO;
4+
using NLog;
5+
using NLog.Config;
6+
using NLog.Targets;
7+
using NServiceBus.AcceptanceTesting.Support;
8+
using NServiceBus.Logging.Loggers.NLogAdapter;
9+
10+
public class ExternalIntegrationsManagementEndpointSetup : ManagementEndpointSetup
11+
{
12+
protected override LoggingConfiguration SetupLogging(EndpointConfiguration endpointConfiguration)
13+
{
14+
var logDir = ".\\logfiles\\";
15+
16+
Directory.CreateDirectory(logDir);
17+
18+
var logFile = Path.Combine(logDir, endpointConfiguration.EndpointName + ".txt");
19+
20+
if (File.Exists(logFile))
21+
{
22+
File.Delete(logFile);
23+
}
24+
25+
var logLevel = "ERROR";
26+
27+
var nlogConfig = new LoggingConfiguration();
28+
29+
var fileTarget = new FileTarget
30+
{
31+
FileName = logFile,
32+
};
33+
34+
nlogConfig.LoggingRules.Add(new LoggingRule("Raven.*", LogLevel.Warn, fileTarget) { Final = true });
35+
nlogConfig.LoggingRules.Add(new LoggingRule("*", LogLevel.FromString(logLevel), fileTarget));
36+
nlogConfig.LoggingRules.Add(new LoggingRule("ServiceControl.ExternalIntegrations.*", LogLevel.Debug, fileTarget));
37+
nlogConfig.AddTarget("debugger", fileTarget);
38+
NLogConfigurator.Configure(new object[] { fileTarget }, logLevel);
39+
return nlogConfig;
40+
}
41+
}
42+
}

src/ServiceControl.AcceptanceTests/Contexts/ManagementEndpointSetup.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,12 +42,12 @@ public Configure GetConfiguration(RunDescriptor runDescriptor, EndpointConfigura
4242
}
4343
}
4444

45-
SetupLogging(endpointConfiguration);
45+
LogManager.Configuration = SetupLogging(endpointConfiguration);
4646

4747
return Configure.Instance;
4848
}
4949

50-
static void SetupLogging(EndpointConfiguration endpointConfiguration)
50+
protected virtual LoggingConfiguration SetupLogging(EndpointConfiguration endpointConfiguration)
5151
{
5252
var logDir = ".\\logfiles\\";
5353

@@ -73,7 +73,7 @@ static void SetupLogging(EndpointConfiguration endpointConfiguration)
7373
nlogConfig.LoggingRules.Add(new LoggingRule("*", LogLevel.FromString(logLevel), fileTarget));
7474
nlogConfig.AddTarget("debugger", fileTarget);
7575
NLogConfigurator.Configure(new object[] {fileTarget}, logLevel);
76-
LogManager.Configuration = nlogConfig;
76+
return nlogConfig;
7777
}
7878
}
7979
}
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
namespace ServiceBus.Management.AcceptanceTests.ExternalIntegrations
2+
{
3+
using NServiceBus;
4+
using ServiceBus.Management.AcceptanceTests.Contexts;
5+
6+
public class JSonServer : DefaultServer
7+
{
8+
public override void SetSerializer(Configure configure)
9+
{
10+
Configure.Serialization.Json();
11+
}
12+
}
13+
}

0 commit comments

Comments
 (0)