Update Azure Blob DataBus to ClaimCheck

Author: kentdr

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

@@ -2,7 +2,6 @@
 using NServiceBus;
 using NServiceBus.Logging;
 
-#pragma warning disable CS0618 // Type or member is obsolete
 #region MessageWithLargePayloadHandler
 
 public class MessageWithLargePayloadHandler :
@@ -18,4 +17,3 @@ public Task Handle(MessageWithLargePayload message, IMessageHandlerContext conte
 }
 
 #endregion
-#pragma warning restore CS0618 // Type or member is obsolete

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

@@ -1,5 +1,6 @@
 using Azure.Storage.Blobs;
 using NServiceBus;
+using NServiceBus.ClaimCheck;
 using System;
 using System.Threading.Tasks;
 
@@ -11,11 +12,11 @@ static async Task Main()
         var endpointConfiguration = new EndpointConfiguration("Samples.AzureBlobStorageDataBus.Receiver");
 
         var blobServiceClient = new BlobServiceClient("UseDevelopmentStorage=true");
-#pragma warning disable CS0618 // Type or member is obsolete
-        var dataBus = endpointConfiguration.UseDataBus<AzureDataBus, SystemJsonDataBusSerializer>()
+
+        var claimCheck = endpointConfiguration.UseClaimCheck<AzureDataBus, SystemJsonClaimCheckSerializer>()
             .Container("testcontainer")
             .UseBlobServiceClient(blobServiceClient);
-#pragma warning restore CS0618 // Type or member is obsolete
+
 
         endpointConfiguration.UseSerialization<SystemJsonSerializer>();
         endpointConfiguration.UseTransport(new LearningTransport());

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

@@ -6,7 +6,7 @@
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="NServiceBus" Version="9.*" />
-    <PackageReference Include="NServiceBus.DataBus.AzureBlobStorage" Version="6.0.*" />
+    <PackageReference Include="NServiceBus.DataBus.AzureBlobStorage" Version="6.1.1-alpha.1" />
     <ProjectReference Include="..\Shared\Shared.csproj" />
   </ItemGroup>
 </Project>

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

@@ -2,6 +2,7 @@
 using NServiceBus;
 using System;
 using System.Threading.Tasks;
+using NServiceBus.ClaimCheck;
 
 class Program
 {
@@ -13,11 +14,10 @@ static async Task Main()
         #region ConfiguringDataBusLocation
 
         var blobServiceClient = new BlobServiceClient("UseDevelopmentStorage=true");
-#pragma warning disable CS0618 // Type or member is obsolete
-        var dataBus = endpointConfiguration.UseDataBus<AzureDataBus, SystemJsonDataBusSerializer>()
+
+        var claimCheck = endpointConfiguration.UseClaimCheck<AzureDataBus, SystemJsonClaimCheckSerializer>()
             .Container("testcontainer")
             .UseBlobServiceClient(blobServiceClient);
-#pragma warning restore CS0618 // Type or member is obsolete
 
         #endregion
 
@@ -54,18 +54,16 @@ static async Task SendMessageLargePayload(IMessageSession messageSession)
     {
         Console.WriteLine("Sending message...");
 
-#pragma warning disable CS0618 // Type or member is obsolete
         #region SendMessageLargePayload
 
         var message = new MessageWithLargePayload
         {
             Description = "This message contains a large payload that will be sent on the Azure data bus",
-            LargePayload = new DataBusProperty<byte[]>(new byte[1024 * 1024 * 5]) // 5MB
+            LargePayload = new ClaimCheckProperty<byte[]>(new byte[1024 * 1024 * 5]) // 5MB
         };
         await messageSession.Send("Samples.AzureBlobStorageDataBus.Receiver", message);
 
         #endregion
-#pragma warning restore CS0618 // Type or member is obsolete
 
         Console.WriteLine("Message sent.");
     }

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

@@ -5,7 +5,7 @@
     <LangVersion>12.0</LangVersion>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="NServiceBus.DataBus.AzureBlobStorage" Version="6.0.*" />
+    <PackageReference Include="NServiceBus.DataBus.AzureBlobStorage" Version="6.1.1-alpha.1" />
     <PackageReference Include="NServiceBus" Version="9.*" />
     <ProjectReference Include="..\Shared\Shared.csproj" />
   </ItemGroup>

samples/databus/blob-storage-databus/ABSDataBus_6/Shared/MessageWithLargePayload.cs

@@ -1,15 +1,14 @@
 using NServiceBus;
+using NServiceBus.ClaimCheck;
 
-#pragma warning disable CS0618 // Type or member is obsolete
 #region MessageWithLargePayload
 
 [TimeToBeReceived("00:03:00")]
 public class MessageWithLargePayload :
     ICommand
 {
-    public DataBusProperty<byte[]> LargePayload { get; set; }
+    public ClaimCheckProperty<byte[]> LargePayload { get; set; }
     public string Description { get; set; }
 }
 
 #endregion
-#pragma warning restore CS0618 // Type or member is obsolete

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

@@ -5,5 +5,6 @@
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="NServiceBus" Version="9.*" />
+    <PackageReference Include="NServiceBus.ClaimCheck" Version="1.0.0-alpha.1" />
   </ItemGroup>
 </Project>