Skip to content

Commit 67465f8

Browse files
committed
Update databus custom serializer sample
1 parent 76ab4b1 commit 67465f8

File tree

9 files changed

+15
-11
lines changed

9 files changed

+15
-11
lines changed
File renamed without changes.
File renamed without changes.

samples/databus/custom-serializer/DataBus_1/Receiver/Program.cs renamed to samples/databus/custom-serializer/ClaimCheck_1/Receiver/Program.cs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
using Shared;
33
using System;
44
using System.Threading.Tasks;
5+
using NServiceBus.ClaimCheck;
56

67
class Program
78
{
@@ -12,8 +13,8 @@ static async Task Main()
1213

1314
#region ConfigureReceiverCustomDataBusSerializer
1415

15-
var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, BsonDataBusSerializer>();
16-
dataBus.BasePath(@"..\..\..\..\storage");
16+
var claimCheck = endpointConfiguration.UseClaimCheck<FileShareClaimCheck, BsonClaimCheckSerializer>();
17+
claimCheck.BasePath(@"..\..\..\..\storage");
1718

1819
#endregion
1920

samples/databus/custom-serializer/DataBus_1/Receiver/Receiver.csproj renamed to samples/databus/custom-serializer/ClaimCheck_1/Receiver/Receiver.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,6 @@
66
</PropertyGroup>
77
<ItemGroup>
88
<ProjectReference Include="..\Shared\Shared.csproj" />
9-
<PackageReference Include="NServiceBus.ClaimCheck.DataBus" Version="1.*" />
9+
<PackageReference Include="NServiceBus.ClaimCheck" Version="1.0.0-alpha.1" />
1010
</ItemGroup>
1111
</Project>

samples/databus/custom-serializer/DataBus_1/Sender/Program.cs renamed to samples/databus/custom-serializer/ClaimCheck_1/Sender/Program.cs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
using System.Collections.Generic;
55
using System.Linq;
66
using System.Threading.Tasks;
7+
using NServiceBus.ClaimCheck;
78

89
class Program
910
{
@@ -14,8 +15,8 @@ static async Task Main()
1415

1516
#region ConfigureSenderCustomDataBusSerializer
1617

17-
var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, BsonDataBusSerializer>();
18-
dataBus.BasePath(@"..\..\..\..\storage");
18+
var claimCheck = endpointConfiguration.UseClaimCheck<FileShareClaimCheck, BsonClaimCheckSerializer>();
19+
claimCheck.BasePath(@"..\..\..\..\storage");
1920

2021
#endregion
2122

@@ -47,7 +48,7 @@ static Task SendMessageLargePayload(IEndpointInstance endpointInstance)
4748
var message = new MessageWithLargePayload
4849
{
4950
SomeProperty = "This message contains a large collection that will be sent on the data bus",
50-
LargeData = new DataBusProperty<Measurement[]>(measurements)
51+
LargeData = new ClaimCheckProperty<Measurement[]>(measurements)
5152
};
5253
Console.WriteLine(@"Message send, the payload is stored in: ..\..\..\storage");
5354
return endpointInstance.Send("Samples.DataBus.Receiver", message);

samples/databus/custom-serializer/DataBus_1/Sender/Sender.csproj renamed to samples/databus/custom-serializer/ClaimCheck_1/Sender/Sender.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,6 @@
66
</PropertyGroup>
77
<ItemGroup>
88
<ProjectReference Include="..\Shared\Shared.csproj" />
9-
<PackageReference Include="NServiceBus.ClaimCheck.DataBus" Version="1.*" />
9+
<PackageReference Include="NServiceBus.ClaimCheck" Version="1.0.0-alpha.1" />
1010
</ItemGroup>
1111
</Project>

samples/databus/custom-serializer/DataBus_1/Shared/BsonDataBusSerializer.cs renamed to samples/databus/custom-serializer/ClaimCheck_1/Shared/BsonDataBusSerializer.cs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
using System.Text;
2+
using NServiceBus.ClaimCheck;
23

34
namespace Shared
45
{
@@ -10,8 +11,8 @@ namespace Shared
1011

1112
#region CustomDataBusSerializer
1213

13-
public class BsonDataBusSerializer :
14-
IDataBusSerializer
14+
public class BsonClaimCheckSerializer :
15+
IClaimCheckSerializer
1516
{
1617
public void Serialize(object databusProperty, Stream stream)
1718
{

samples/databus/custom-serializer/DataBus_1/Shared/MessageWithLargePayload.cs renamed to samples/databus/custom-serializer/ClaimCheck_1/Shared/MessageWithLargePayload.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,13 @@
11
using System;
22
using NServiceBus;
3+
using NServiceBus.ClaimCheck;
34

45
[TimeToBeReceived("00:01:00")]
56
public class MessageWithLargePayload :
67
ICommand
78
{
89
public string SomeProperty { get; set; }
9-
public DataBusProperty<Measurement[]> LargeData { get; set; }
10+
public ClaimCheckProperty<Measurement[]> LargeData { get; set; }
1011
}
1112

1213
[Serializable]

samples/databus/custom-serializer/DataBus_1/Shared/Shared.csproj renamed to samples/databus/custom-serializer/ClaimCheck_1/Shared/Shared.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,6 @@
66
<ItemGroup>
77
<PackageReference Include="Newtonsoft.Json" Version="13.*" />
88
<PackageReference Include="Newtonsoft.Json.Bson" Version="1.*" />
9-
<PackageReference Include="NServiceBus.ClaimCheck.DataBus" Version="1.*" />
9+
<PackageReference Include="NServiceBus.ClaimCheck" Version="1.0.0-alpha.1" />
1010
</ItemGroup>
1111
</Project>

0 commit comments

Comments
 (0)