Skip to content

Commit ce9ad2a

Browse files
committed
Migrate to new claimcheck lib
1 parent 776b2f4 commit ce9ad2a

File tree

7 files changed

+16
-18
lines changed

7 files changed

+16
-18
lines changed

samples/databus/blob-storage-databus/ABSDataBus_6/Receiver/MessageWithLargePayloadHandler.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22
using NServiceBus;
33
using NServiceBus.Logging;
44

5-
#pragma warning disable CS0618 // Type or member is obsolete
65
#region MessageWithLargePayloadHandler
76

87
public class MessageWithLargePayloadHandler :
@@ -17,5 +16,4 @@ public Task Handle(MessageWithLargePayload message, IMessageHandlerContext conte
1716
}
1817
}
1918

20-
#endregion
21-
#pragma warning restore CS0618 // Type or member is obsolete
19+
#endregion

samples/databus/blob-storage-databus/ABSDataBus_6/Receiver/Program.cs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,9 @@
11
using Azure.Storage.Blobs;
22
using NServiceBus;
3+
using NServiceBus.DataBus.AzureBlobStorage;
34
using System;
45
using System.Threading.Tasks;
6+
using NServiceBus.ClaimCheck.DataBus;
57

68
class Program
79
{
@@ -11,11 +13,10 @@ static async Task Main()
1113
var endpointConfiguration = new EndpointConfiguration("Samples.AzureBlobStorageDataBus.Receiver");
1214

1315
var blobServiceClient = new BlobServiceClient("UseDevelopmentStorage=true");
14-
#pragma warning disable CS0618 // Type or member is obsolete
15-
var dataBus = endpointConfiguration.UseDataBus<AzureDataBus, SystemJsonDataBusSerializer>()
16+
17+
var dataBus = endpointConfiguration.UseClaimCheck<AzureDataBus, SystemJsonClaimCheckSerializer>()
1618
.Container("testcontainer")
1719
.UseBlobServiceClient(blobServiceClient);
18-
#pragma warning restore CS0618 // Type or member is obsolete
1920

2021
endpointConfiguration.UseSerialization<SystemJsonSerializer>();
2122
endpointConfiguration.UseTransport(new LearningTransport());

samples/databus/blob-storage-databus/ABSDataBus_6/Receiver/Receiver.csproj

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

samples/databus/blob-storage-databus/ABSDataBus_6/Sender/Program.cs

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,8 @@
22
using NServiceBus;
33
using System;
44
using System.Threading.Tasks;
5+
using NServiceBus.ClaimCheck.DataBus;
6+
using NServiceBus.DataBus.AzureBlobStorage;
57

68
class Program
79
{
@@ -13,11 +15,10 @@ static async Task Main()
1315
#region ConfiguringDataBusLocation
1416

1517
var blobServiceClient = new BlobServiceClient("UseDevelopmentStorage=true");
16-
#pragma warning disable CS0618 // Type or member is obsolete
17-
var dataBus = endpointConfiguration.UseDataBus<AzureDataBus, SystemJsonDataBusSerializer>()
18+
19+
var dataBus = endpointConfiguration.UseClaimCheck<AzureDataBus, SystemJsonClaimCheckSerializer>()
1820
.Container("testcontainer")
1921
.UseBlobServiceClient(blobServiceClient);
20-
#pragma warning restore CS0618 // Type or member is obsolete
2122

2223
#endregion
2324

@@ -54,18 +55,16 @@ static async Task SendMessageLargePayload(IMessageSession messageSession)
5455
{
5556
Console.WriteLine("Sending message...");
5657

57-
#pragma warning disable CS0618 // Type or member is obsolete
5858
#region SendMessageLargePayload
5959

6060
var message = new MessageWithLargePayload
6161
{
6262
Description = "This message contains a large payload that will be sent on the Azure data bus",
63-
LargePayload = new DataBusProperty<byte[]>(new byte[1024 * 1024 * 5]) // 5MB
63+
LargePayload = new ClaimCheckProperty<byte[]>(new byte[1024 * 1024 * 5]) // 5MB
6464
};
6565
await messageSession.Send("Samples.AzureBlobStorageDataBus.Receiver", message);
6666

6767
#endregion
68-
#pragma warning restore CS0618 // Type or member is obsolete
6968

7069
Console.WriteLine("Message sent.");
7170
}

samples/databus/blob-storage-databus/ABSDataBus_6/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.DataBus.AzureBlobStorage" Version="6.0.*" />
8+
<PackageReference Include="NServiceBus.DataBus.AzureBlobStorage" Version="6.2.0-alpha.0.7" />
99
<PackageReference Include="NServiceBus" Version="9.*" />
1010
<ProjectReference Include="..\Shared\Shared.csproj" />
1111
</ItemGroup>
Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,14 @@
11
using NServiceBus;
2+
using NServiceBus.ClaimCheck.DataBus;
23

3-
#pragma warning disable CS0618 // Type or member is obsolete
44
#region MessageWithLargePayload
55

66
[TimeToBeReceived("00:03:00")]
77
public class MessageWithLargePayload :
88
ICommand
99
{
10-
public DataBusProperty<byte[]> LargePayload { get; set; }
10+
public ClaimCheckProperty<byte[]> LargePayload { get; set; }
1111
public string Description { get; set; }
1212
}
1313

1414
#endregion
15-
#pragma warning restore CS0618 // Type or member is obsolete

samples/databus/blob-storage-databus/ABSDataBus_6/Shared/Shared.csproj

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
<LangVersion>12.0</LangVersion>
55
</PropertyGroup>
66
<ItemGroup>
7-
<PackageReference Include="NServiceBus" Version="9.*" />
7+
<PackageReference Include="NServiceBus" Version="9.*" />
8+
<PackageReference Include="NServiceBus.ClaimCheck.DataBus" Version="1.1.0-alpha.0.16" />
89
</ItemGroup>
910
</Project>

0 commit comments

Comments
 (0)