Fix RabbitMQ sample (#156)

Author: tobias-tengler

.github/workflows/test-matrix.yml

@@ -4,7 +4,7 @@ on:
   workflow_call:
     inputs:
       include_docker_info:
-        description: 'Whether to include Docker information step'
+        description: "Whether to include Docker information step"
         required: false
         type: boolean
         default: false
@@ -18,7 +18,7 @@ jobs:
       - uses: actions/checkout@v2
       - id: set-matrix
         run: |
-          PROJECTS=$(find . -name '*.Tests.csproj' | sed 's|.*/\([^/]*\)\.csproj|\1|' | jq -R -s -c 'split("\n")[:-1]')
+          PROJECTS=$(find . \( -name '*.Tests.csproj' -o -name '*.Sample.csproj' \) | sed 's|.*/\([^/]*\)\.csproj|\1|' | jq -R -s -c 'split("\n")[:-1]')
           FRAMEWORKS='["net8.0", "net9.0","net10.0"]'
           MATRIX=$(jq -n \
             --argjson projects "$PROJECTS" \
@@ -35,22 +35,22 @@ jobs:
     runs-on: ubuntu-latest
     name: ${{ matrix.test_project }} ${{ matrix.framework }}
     strategy:
-      matrix: 
+      matrix:
         test_project: ${{fromJson(needs.prepare.outputs.matrix).test_project}}
         framework: ${{fromJson(needs.prepare.outputs.matrix).framework}}
       fail-fast: false
     steps:
       - name: Checkout code
         uses: actions/checkout@v2
-      
+
       - name: Setup .NET
         uses: actions/setup-dotnet@v4
         with:
           dotnet-version: |
             8
             9
             10
-      
+
       - name: Docker Information
         if: ${{ inputs.include_docker_info }}
         run: |

…udServiceBus/AzureCloudServiceBus.csproj …ceBus/AzureCloudServiceBus.Sample.csprojsamples/AzureCloudServiceBus/AzureCloudServiceBus.csproj renamed to samples/AzureCloudServiceBus/AzureCloudServiceBus.Sample.csproj samples/AzureCloudServiceBus/AzureCloudServiceBus.csproj renamed to samples/AzureCloudServiceBus/AzureCloudServiceBus.Sample.csproj

@@ -1,6 +1,6 @@
 <Project>
   <PropertyGroup>
-    <TargetFramework>net9.0</TargetFramework>
+    <TargetFramework>net10.0</TargetFramework>
     <IsPackable>false</IsPackable>
     <ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
   </PropertyGroup>

samples/Compose/Compose.csproj samples/Compose/Compose.Sample.csprojsamples/Compose/Compose.csproj renamed to samples/Compose/Compose.Sample.csproj

@@ -34,23 +34,24 @@ public async Task SendEvent_Received()
             var broker = new OrderEventBroker(connectionFactory);
 
             // Act
-            broker.SendEvent(ev);
+            await broker.SendEventAsync(ev);
 
             OrderEvent resultEvent = null;
 
-            using IConnection connection = connectionFactory.CreateConnection();
-            using IModel channel = connection.CreateModel();
-            channel.QueueDeclare(
+            await using IConnection connection = await connectionFactory.CreateConnectionAsync();
+            await using IChannel channel = await connection.CreateChannelAsync();
+
+            await channel.QueueDeclareAsync(
                 OrderEventBroker.QueueName,
                 false,
                 false,
                 false,
                 null);
 
-            BasicGetResult queueResult = channel.BasicGet(OrderEventBroker.QueueName, true);
+            BasicGetResult queueResult = await channel.BasicGetAsync(OrderEventBroker.QueueName, true);
             if (queueResult != null)
             {
-                var json = Encoding.UTF8.GetString(queueResult.Body);
+                var json = Encoding.UTF8.GetString(queueResult.Body.Span);
                 resultEvent = JsonSerializer.Deserialize<OrderEvent>(json);
             }
 

samples/Directory.Build.props

@@ -19,22 +19,24 @@ public OrderEventBroker(IConnectionFactory connectionFactory)
             _connectionFactory = connectionFactory;
         }
 
-        public void SendEvent(OrderEvent @event)
+        public async Task SendEventAsync(OrderEvent @event)
         {
-            using IConnection connection = _connectionFactory.CreateConnection();
-            using IModel channel = connection.CreateModel();
-            channel.QueueDeclare(
+            await using IConnection connection = await _connectionFactory.CreateConnectionAsync();
+            await using IChannel channel = await connection.CreateChannelAsync();
+
+            await channel.QueueDeclareAsync(
                 QueueName,
                 false,
                 false,
                 false,
                 null);
 
-            channel.BasicPublish(
-                string.Empty,
-                QueueName,
-                null,
-                BuildMessage(@event));
+            await channel.BasicPublishAsync(
+                exchange: string.Empty,
+                routingKey: QueueName,
+                mandatory: false,
+                basicProperties: new BasicProperties(),
+                body: BuildMessage(@event));
         }
 
         private static byte[] BuildMessage(OrderEvent @event)