Update dotnet tutorials to use 7.0.0

dotnet/.gitattributes

@@ -0,0 +1,14 @@
+# Set the default behavior, in case people don't have core.autocrlf set.
+* text=auto
+
+# Auto detect text files and perform LF normalization
+*.cs text=auto eol=lf
+*.txt text=auto
+
+# Declare files that will always have CRLF line endings on checkout.
+*.sln text eol=crlf
+*.csproj text eol=crlf
+
+# Custom for Visual Studio
+*.cs     diff=csharp
+

dotnet/EmitLog/EmitLog.cs

@@ -1,18 +1,15 @@
-using System.Text;
 using RabbitMQ.Client;
+using System.Text;
 
 var factory = new ConnectionFactory { HostName = "localhost" };
-using var connection = factory.CreateConnection();
-using var channel = connection.CreateModel();
+using var connection = await factory.CreateConnectionAsync();
+using var channel = await connection.CreateChannelAsync();
 
-channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
+await channel.ExchangeDeclareAsync(exchange: "logs", type: ExchangeType.Fanout);
 
 var message = GetMessage(args);
 var body = Encoding.UTF8.GetBytes(message);
-channel.BasicPublish(exchange: "logs",
-                     routingKey: string.Empty,
-                     basicProperties: null,
-                     body: body);
+await channel.BasicPublishAsync(exchange: "logs", routingKey: string.Empty, body: body);
 Console.WriteLine($" [x] Sent {message}");
 
 Console.WriteLine(" Press [enter] to exit.");
@@ -21,4 +18,4 @@
 static string GetMessage(string[] args)
 {
     return ((args.Length > 0) ? string.Join(" ", args) : "info: Hello World!");
-}
+}

dotnet/EmitLog/EmitLog.csproj

@@ -1,14 +1,14 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net7.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <OutputType>Exe</OutputType>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
+    <PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
   </ItemGroup>
 
 </Project>

dotnet/EmitLogDirect/EmitLogDirect.cs

@@ -1,22 +1,17 @@
-using System.Text;
 using RabbitMQ.Client;
+using System.Text;
 
 var factory = new ConnectionFactory { HostName = "localhost" };
-using var connection = factory.CreateConnection();
-using var channel = connection.CreateModel();
+using var connection = await factory.CreateConnectionAsync();
+using var channel = await connection.CreateChannelAsync();
 
-channel.ExchangeDeclare(exchange: "direct_logs", type: ExchangeType.Direct);
+await channel.ExchangeDeclareAsync(exchange: "direct_logs", type: ExchangeType.Direct);
 
 var severity = (args.Length > 0) ? args[0] : "info";
-var message = (args.Length > 1)
-                    ? string.Join(" ", args.Skip(1).ToArray())
-                    : "Hello World!";
+var message = (args.Length > 1) ? string.Join(" ", args.Skip(1).ToArray()) : "Hello World!";
 var body = Encoding.UTF8.GetBytes(message);
-channel.BasicPublish(exchange: "direct_logs",
-                     routingKey: severity,
-                     basicProperties: null,
-                     body: body);
+await channel.BasicPublishAsync(exchange: "direct_logs", routingKey: severity, body: body);
 Console.WriteLine($" [x] Sent '{severity}':'{message}'");
 
 Console.WriteLine(" Press [enter] to exit.");
-Console.ReadLine();
+Console.ReadLine();

dotnet/EmitLogDirect/EmitLogDirect.csproj

@@ -1,14 +1,14 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net7.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <OutputType>Exe</OutputType>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
+    <PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
   </ItemGroup>
 
 </Project>

dotnet/EmitLogTopic/EmitLogTopic.cs

@@ -1,20 +1,14 @@
-using System.Text;
 using RabbitMQ.Client;
+using System.Text;
 
 var factory = new ConnectionFactory { HostName = "localhost" };
+using var connection = await factory.CreateConnectionAsync();
+using var channel = await connection.CreateChannelAsync();
 
-using var connection = factory.CreateConnection();
-using var channel = connection.CreateModel();
-
-channel.ExchangeDeclare(exchange: "topic_logs", type: ExchangeType.Topic);
+await channel.ExchangeDeclareAsync(exchange: "topic_logs", type: ExchangeType.Topic);
 
 var routingKey = (args.Length > 0) ? args[0] : "anonymous.info";
-var message = (args.Length > 1)
-                    ? string.Join(" ", args.Skip(1).ToArray())
-                    : "Hello World!";
+var message = (args.Length > 1) ? string.Join(" ", args.Skip(1).ToArray()) : "Hello World!";
 var body = Encoding.UTF8.GetBytes(message);
-channel.BasicPublish(exchange: "topic_logs",
-                     routingKey: routingKey,
-                     basicProperties: null,
-                     body: body);
-Console.WriteLine($" [x] Sent '{routingKey}':'{message}'");
+await channel.BasicPublishAsync(exchange: "topic_logs", routingKey: routingKey, body: body);
+Console.WriteLine($" [x] Sent '{routingKey}':'{message}'");

dotnet/EmitLogTopic/EmitLogTopic.csproj

@@ -1,14 +1,14 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net7.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <OutputType>Exe</OutputType>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>    
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
+    <PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
   </ItemGroup>
 
 </Project>

dotnet/NewTask/NewTask.cs

@@ -1,32 +1,26 @@
-using System.Text;
 using RabbitMQ.Client;
+using System.Text;
 
 var factory = new ConnectionFactory { HostName = "localhost" };
-using var connection = factory.CreateConnection();
-using var channel = connection.CreateModel();
+using var connection = await factory.CreateConnectionAsync();
+using var channel = await connection.CreateChannelAsync();
 
-channel.QueueDeclare(queue: "task_queue",
-                     durable: true,
-                     exclusive: false,
-                     autoDelete: false,
-                     arguments: null);
+await channel.QueueDeclareAsync(queue: "task_queue", durable: true, exclusive: false,
+    autoDelete: false, arguments: null);
 
 var message = GetMessage(args);
 var body = Encoding.UTF8.GetBytes(message);
 
-var properties = channel.CreateBasicProperties();
-properties.Persistent = true;
+var properties = new BasicProperties
+{
+    Persistent = true
+};
 
-channel.BasicPublish(exchange: string.Empty,
-                     routingKey: "task_queue",
-                     basicProperties: properties,
-                     body: body);
+await channel.BasicPublishAsync(exchange: string.Empty, routingKey: "task_queue", mandatory: true,
+    basicProperties: properties, body: body);
 Console.WriteLine($" [x] Sent {message}");
 
-Console.WriteLine(" Press [enter] to exit.");
-Console.ReadLine();
-
 static string GetMessage(string[] args)
 {
     return ((args.Length > 0) ? string.Join(" ", args) : "Hello World!");
-}
+}

dotnet/NewTask/NewTask.csproj

@@ -1,14 +1,14 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net7.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <OutputType>Exe</OutputType>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>      
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="RabbitMQ.Client" Version="6.4.0" />
+    <PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
   </ItemGroup>
 
 </Project>