Skip to content

Commit b26b137

Browse files
committed
Update file share sample
1 parent faa22cb commit b26b137

File tree

9 files changed

+13
-10
lines changed

9 files changed

+13
-10
lines changed
File renamed without changes.
File renamed without changes.
Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,21 @@
11
using NServiceBus;
22
using System;
33
using System.Threading.Tasks;
4+
using NServiceBus.ClaimCheck;
45

56
class Program
67
{
78
static async Task Main()
89
{
910
Console.Title = "Receiver";
1011
var endpointConfiguration = new EndpointConfiguration("Samples.DataBus.Receiver");
11-
var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>();
12-
dataBus.BasePath(@"..\..\..\..\storage");
12+
var claimCheck = endpointConfiguration.UseClaimCheck<FileShareClaimCheck, SystemJsonClaimCheckSerializer>();
13+
claimCheck.BasePath(@"..\..\..\..\storage");
1314
endpointConfiguration.UseSerialization<SystemJsonSerializer>();
1415
endpointConfiguration.UseTransport(new LearningTransport());
1516
var endpointInstance = await Endpoint.Start(endpointConfiguration);
1617
Console.WriteLine("Press any key to exit");
1718
Console.ReadKey();
1819
await endpointInstance.Stop();
1920
}
20-
}
21+
}

samples/databus/file-share-databus/DataBus_1/Receiver/Receiver.csproj renamed to samples/databus/file-share-databus/ClaimCheck_1/Receiver/Receiver.csproj

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

samples/databus/file-share-databus/DataBus_1/Sender/Program.cs renamed to samples/databus/file-share-databus/ClaimCheck_1/Sender/Program.cs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
using NServiceBus;
22
using System;
33
using System.Threading.Tasks;
4+
using NServiceBus.ClaimCheck;
45

56
class Program
67
{
@@ -11,8 +12,8 @@ static async Task Main()
1112

1213
#region ConfigureDataBus
1314

14-
var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>();
15-
dataBus.BasePath(@"..\..\..\..\storage");
15+
var claimCheck = endpointConfiguration.UseClaimCheck<FileShareClaimCheck, SystemJsonClaimCheckSerializer>();
16+
claimCheck.BasePath(@"..\..\..\..\storage");
1617

1718
#endregion
1819

@@ -53,7 +54,7 @@ static async Task SendMessageLargePayload(IEndpointInstance endpointInstance)
5354
var message = new MessageWithLargePayload
5455
{
5556
SomeProperty = "This message contains a large blob that will be sent on the data bus",
56-
LargeBlob = new DataBusProperty<byte[]>(new byte[1024*1024*5]) //5MB
57+
LargeBlob = new ClaimCheckProperty<byte[]>(new byte[1024*1024*5]) //5MB
5758
};
5859
await endpointInstance.Send("Samples.DataBus.Receiver", message);
5960

samples/databus/file-share-databus/DataBus_1/Sender/Sender.csproj renamed to samples/databus/file-share-databus/ClaimCheck_1/Sender/Sender.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<LangVersion>12.0</LangVersion>
66
</PropertyGroup>
77
<ItemGroup>
8-
<PackageReference Include="NServiceBus.ClaimCheck.DataBus" Version="1.*" />
8+
<PackageReference Include="NServiceBus.ClaimCheck" Version="1.0.0-alpha.1" />
99
<ProjectReference Include="..\Shared\Shared.csproj" />
1010
</ItemGroup>
1111
</Project>
File renamed without changes.

samples/databus/file-share-databus/DataBus_1/Shared/MessageWithLargePayload.cs renamed to samples/databus/file-share-databus/ClaimCheck_1/Shared/MessageWithLargePayload.cs

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

34
#region MessageWithLargePayload
45

@@ -8,7 +9,7 @@ public class MessageWithLargePayload :
89
ICommand
910
{
1011
public string SomeProperty { get; set; }
11-
public DataBusProperty<byte[]> LargeBlob { get; set; }
12+
public ClaimCheckProperty<byte[]> LargeBlob { get; set; }
1213
}
1314

1415
#endregion

samples/databus/file-share-databus/DataBus_1/Shared/Shared.csproj renamed to samples/databus/file-share-databus/ClaimCheck_1/Shared/Shared.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,6 @@
44
<LangVersion>12.0</LangVersion>
55
</PropertyGroup>
66
<ItemGroup>
7-
<PackageReference Include="NServiceBus.ClaimCheck.DataBus" Version="1.*" />
7+
<PackageReference Include="NServiceBus.ClaimCheck" Version="1.0.0-alpha.1" />
88
</ItemGroup>
99
</Project>

0 commit comments

Comments
 (0)