Skip to content

Commit 29db5ae

Browse files
WilliamBZAkentdr
WilliamBZA
authored and
kentdr
committed
Fix snippets
1 parent 0415b2c commit 29db5ae

40 files changed

+611
-29
lines changed

‎Snippets/BinaryDataBusSerializer/BinaryDataBusSerializer_1/Usage.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,10 @@ class Usage
55
{
66
Usage(EndpointConfiguration endpointConfiguration)
77
{
8-
#region BinaryDataBusUsage
98
#pragma warning disable CS0618 // Type or member is obsolete
9+
#region BinaryDataBusUsage
1010
endpointConfiguration.UseDataBus<FileShareDataBus, BinaryFormatterDataBusSerializer>();
11-
#pragma warning restore CS0618 // Type or member is obsolete
1211
#endregion
12+
#pragma warning restore CS0618 // Type or member is obsolete
1313
}
1414
}

‎Snippets/DataBus/Core_7/Core_7.csproj

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
<PropertyGroup>
3+
<TargetFramework>net48</TargetFramework>
4+
<RootNamespace>Core7</RootNamespace>
5+
<PlatformTarget>x64</PlatformTarget>
6+
</PropertyGroup>
7+
<ItemGroup>
8+
<PackageReference Include="Microsoft.ServiceFabric.Services" Version="2.*" />
9+
<PackageReference Include="NServiceBus" Version="7.*" />
10+
<PackageReference Include="NServiceBus.Autofac" Version="7.*" />
11+
<PackageReference Include="NServiceBus.Callbacks" Version="3.*" />
12+
<PackageReference Include="NServiceBus.Encryption.MessageProperty" Version="2.*" />
13+
<PackageReference Include="NServiceBus.Metrics.ServiceControl" Version="3.*" />
14+
<PackageReference Include="Newtonsoft.Json" Version="13.*" />
15+
<PackageReference Include="NUnit" Version="3.*" />
16+
<PackageReference Include="System.Reactive" Version="3.*" />
17+
<Reference Include="System.ServiceProcess" />
18+
<Reference Include="System.Web" />
19+
</ItemGroup>
20+
</Project>

‎Snippets/DataBus/Core_7/DataBus/Conventions/MessageWithLargePayload.cs

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+

2+
namespace Core7.DataBus.Conventions
3+
{
4+
5+
#region MessageWithLargePayloadUsingConvention
6+
7+
public class MessageWithLargePayload
8+
{
9+
public string SomeProperty { get; set; }
10+
public byte[] LargeBlobDataBus { get; set; }
11+
}
12+
13+
#endregion
14+
}

‎Snippets/DataBus/Core_7/DataBus/Conventions/Usage.cs

+19
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
namespace Core7.DataBus.Conventions
2+
{
3+
using NServiceBus;
4+
5+
class Usage
6+
{
7+
Usage(EndpointConfiguration endpointConfiguration)
8+
{
9+
#region DefineMessageWithLargePayloadUsingConvention
10+
11+
var conventions = endpointConfiguration.Conventions();
12+
conventions.DefiningDataBusPropertiesAs(
13+
property => property.Name.EndsWith("DataBus"));
14+
15+
#endregion
16+
17+
}
18+
}
19+
}

‎Snippets/DataBus/Core_7/DataBus/Custom/CustomDataBus.cs

+36
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
namespace Core7.DataBus.Custom
2+
{
3+
using System;
4+
using System.IO;
5+
using System.Threading.Tasks;
6+
using NServiceBus.DataBus;
7+
8+
#region CustomDataBus
9+
10+
class CustomDataBus :
11+
IDataBus
12+
{
13+
public Task<Stream> Get(string key)
14+
{
15+
Stream stream = File.OpenRead("blob.dat");
16+
return Task.FromResult(stream);
17+
}
18+
19+
public async Task<string> Put(Stream stream, TimeSpan timeToBeReceived)
20+
{
21+
using (var destination = File.OpenWrite("blob.dat"))
22+
{
23+
await stream.CopyToAsync(destination);
24+
}
25+
return "the-key-of-the-stored-file-such-as-the-full-path";
26+
}
27+
28+
public Task Start()
29+
{
30+
return Task.CompletedTask;
31+
}
32+
}
33+
34+
#endregion
35+
36+
}

‎Snippets/DataBus/Core_7/DataBus/Custom/Definition.cs

+13
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
namespace Core7.DataBus.Custom
2+
{
3+
using System;
4+
using NServiceBus.DataBus;
5+
6+
#region CustomDataBusDefinition
7+
class CustomDatabusDefinition : DataBusDefinition
8+
{
9+
protected override Type ProvidedByFeature()
10+
=> typeof(CustomDatabusFeature);
11+
}
12+
#endregion
13+
}

‎Snippets/DataBus/Core_7/DataBus/Custom/Feature.cs

+18
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
namespace Core7.DataBus.Custom
2+
{
3+
using NServiceBus;
4+
using NServiceBus.Features;
5+
6+
#region CustomDataBusFeature
7+
class CustomDatabusFeature : Feature
8+
{
9+
public CustomDatabusFeature()
10+
=> DependsOn<DataBus>();
11+
12+
protected override void Setup(FeatureConfigurationContext context)
13+
{
14+
context.Container.ConfigureComponent(typeof(CustomDataBus) , DependencyLifecycle.SingleInstance);
15+
}
16+
}
17+
#endregion
18+
}

‎Snippets/DataBus/Core_7/DataBus/Custom/Usage.cs

+15
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
namespace Core7.DataBus.Custom
2+
{
3+
using NServiceBus;
4+
5+
class Usage
6+
{
7+
Usage(EndpointConfiguration endpointConfiguration)
8+
{
9+
#region PluginCustomDataBus
10+
endpointConfiguration.UseDataBus(typeof(CustomDataBus));
11+
12+
#endregion
13+
}
14+
}
15+
}

‎Snippets/DataBus/Core_7/DataBus/DataBusProperty/MessageWithLargePayload.cs

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
namespace Core7.DataBus.DataBusProperty
2+
{
3+
using NServiceBus;
4+
5+
#region MessageWithLargePayload
6+
7+
public class MessageWithLargePayload
8+
{
9+
public string SomeProperty { get; set; }
10+
public DataBusProperty<byte[]> LargeBlob { get; set; }
11+
}
12+
13+
#endregion
14+
}

‎Snippets/DataBus/Core_8/Core_8.csproj

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
<PropertyGroup>
3+
<TargetFramework>net48</TargetFramework>
4+
<RootNamespace>Core8</RootNamespace>
5+
<PlatformTarget>x64</PlatformTarget>
6+
</PropertyGroup>
7+
<ItemGroup>
8+
<PackageReference Include="Microsoft.AspNet.Mvc" Version="5.2.7" />
9+
<PackageReference Include="Microsoft.ServiceFabric.Services" Version="2.*" />
10+
<PackageReference Include="NServiceBus" Version="8.*" />
11+
<PackageReference Include="NServiceBus.Callbacks" Version="4.*" />
12+
<PackageReference Include="NServiceBus.Encryption.MessageProperty" Version="4.*" />
13+
<PackageReference Include="NServiceBus.Metrics.ServiceControl" Version="4.*" />
14+
<PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.*" />
15+
<PackageReference Include="Newtonsoft.Json" Version="13.*" />
16+
<PackageReference Include="NUnit" Version="3.*" />
17+
<PackageReference Include="NUnit3TestAdapter" Version="3.17.0" />
18+
<PackageReference Include="OpenTelemetry" Version="1.*" />
19+
<Reference Include="System.ServiceProcess" />
20+
<Reference Include="System.Web" />
21+
</ItemGroup>
22+
</Project>

‎Snippets/DataBus/Core_8/DataBus/Conventions/MessageWithLargePayload.cs

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+

2+
namespace Core8.DataBus.Conventions
3+
{
4+
5+
#region MessageWithLargePayloadUsingConvention
6+
7+
public class MessageWithLargePayload
8+
{
9+
public string SomeProperty { get; set; }
10+
public byte[] LargeBlobDataBus { get; set; }
11+
}
12+
13+
#endregion
14+
}

‎Snippets/DataBus/Core_8/DataBus/Conventions/Usage.cs

+19
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
namespace Core8.DataBus.Conventions
2+
{
3+
using NServiceBus;
4+
5+
class Usage
6+
{
7+
Usage(EndpointConfiguration endpointConfiguration)
8+
{
9+
#region DefineMessageWithLargePayloadUsingConvention
10+
11+
var conventions = endpointConfiguration.Conventions();
12+
conventions.DefiningDataBusPropertiesAs(
13+
property => property.Name.EndsWith("DataBus"));
14+
15+
#endregion
16+
17+
}
18+
}
19+
}

‎Snippets/DataBus/Core_8/DataBus/Custom/CustomDataBus.cs

+37
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
namespace Core8.DataBus.Custom
2+
{
3+
using System;
4+
using System.IO;
5+
using System.Threading;
6+
using System.Threading.Tasks;
7+
using NServiceBus.DataBus;
8+
9+
#region CustomDataBus
10+
11+
class CustomDataBus :
12+
IDataBus
13+
{
14+
public Task<Stream> Get(string key, CancellationToken cancellationToken)
15+
{
16+
Stream stream = File.OpenRead("blob.dat");
17+
return Task.FromResult(stream);
18+
}
19+
20+
public async Task<string> Put(Stream stream, TimeSpan timeToBeReceived, CancellationToken cancellationToken)
21+
{
22+
using (var destination = File.OpenWrite("blob.dat"))
23+
{
24+
await stream.CopyToAsync(destination, 81920, cancellationToken);
25+
}
26+
return "the-key-of-the-stored-file-such-as-the-full-path";
27+
}
28+
29+
public Task Start(CancellationToken cancellationToken)
30+
{
31+
return Task.CompletedTask;
32+
}
33+
}
34+
35+
#endregion
36+
37+
}

‎Snippets/DataBus/Core_8/DataBus/Custom/Definition.cs

+13
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
namespace Core8.DataBus.Custom
2+
{
3+
using System;
4+
using NServiceBus.DataBus;
5+
6+
#region CustomDataBusDefinition
7+
class CustomDatabusDefinition : DataBusDefinition
8+
{
9+
protected override Type ProvidedByFeature()
10+
=> typeof(CustomDatabusFeature);
11+
}
12+
#endregion
13+
}

‎Snippets/DataBus/Core_8/DataBus/Custom/Feature.cs

+17
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
namespace Core8.DataBus.Custom
2+
{
3+
using Microsoft.Extensions.DependencyInjection;
4+
using NServiceBus.DataBus;
5+
using NServiceBus.Features;
6+
7+
#region CustomDataBusFeature
8+
class CustomDatabusFeature : Feature
9+
{
10+
public CustomDatabusFeature()
11+
=> DependsOn<DataBus>();
12+
13+
protected override void Setup(FeatureConfigurationContext context)
14+
=> context.Services.AddSingleton<IDataBus, CustomDataBus>();
15+
}
16+
#endregion
17+
}

‎Snippets/DataBus/Core_8/DataBus/Custom/Usage.cs

+40
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
namespace Core8.DataBus.Custom
2+
{
3+
using System;
4+
using System.IO;
5+
using NServiceBus;
6+
using NServiceBus.DataBus;
7+
8+
class Usage
9+
{
10+
Usage(EndpointConfiguration endpointConfiguration)
11+
{
12+
#region PluginCustomDataBus
13+
endpointConfiguration.UseDataBus(svc => new CustomDataBus(), new SystemJsonDataBusSerializer());
14+
#endregion
15+
16+
#region SpecifyingSerializer
17+
endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>();
18+
#endregion
19+
20+
#region SpecifyingDeserializer
21+
endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>()
22+
.AddDeserializer<BsonDataBusSerializer>();
23+
#endregion
24+
}
25+
26+
class BsonDataBusSerializer : IDataBusSerializer
27+
{
28+
public void Serialize(object databusProperty, Stream stream)
29+
{
30+
}
31+
32+
public object Deserialize(Type propertyType, Stream stream)
33+
{
34+
return default;
35+
}
36+
37+
public string ContentType { get; }
38+
}
39+
}
40+
}

‎Snippets/DataBus/Core_8/DataBus/DataBusProperty/MessageWithLargePayload.cs

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
namespace Core8.DataBus.DataBusProperty
2+
{
3+
using NServiceBus;
4+
5+
#region MessageWithLargePayload
6+
7+
public class MessageWithLargePayload
8+
{
9+
public string SomeProperty { get; set; }
10+
public DataBusProperty<byte[]> LargeBlob { get; set; }
11+
}
12+
13+
#endregion
14+
}

‎Snippets/DataBus/Core_9/Core_9.csproj

+24
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
3+
<PropertyGroup>
4+
<TargetFramework>net8.0</TargetFramework>
5+
<RootNamespace>Core9</RootNamespace>
6+
</PropertyGroup>
7+
8+
<ItemGroup>
9+
<FrameworkReference Include="Microsoft.AspNetCore.App" />
10+
</ItemGroup>
11+
12+
<ItemGroup>
13+
<PackageReference Include="NServiceBus" Version="9.*" />
14+
<PackageReference Include="NServiceBus.Callbacks" Version="5.*" />
15+
<PackageReference Include="NServiceBus.Encryption.MessageProperty" Version="5.*" />
16+
<PackageReference Include="NServiceBus.Metrics.ServiceControl" Version="5.*" />
17+
<PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.*" />
18+
<PackageReference Include="Newtonsoft.Json" Version="13.*" />
19+
<PackageReference Include="NUnit" Version="3.*" />
20+
<PackageReference Include="NUnit3TestAdapter" Version="3.17.0" />
21+
<PackageReference Include="OpenTelemetry" Version="1.*" />
22+
</ItemGroup>
23+
24+
</Project>

‎Snippets/DataBus/Core_9/DataBus/Conventions/MessageWithLargePayload.cs

+14
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+

2+
namespace Core9.DataBus.Conventions
3+
{
4+
5+
#region MessageWithLargePayloadUsingConvention
6+
7+
public class MessageWithLargePayload
8+
{
9+
public string SomeProperty { get; set; }
10+
public byte[] LargeBlobDataBus { get; set; }
11+
}
12+
13+
#endregion
14+
}

0 commit comments

Comments
 (0)