Update example application

brianpursley · Jul 1, 2024 · 607d971 · 607d971
1 parent 4e9f34f
commit 607d971
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/Npgmq.Example/Program.cs b/Npgmq.Example/Program.cs
@@ -38,14 +38,20 @@
     await connection.OpenAsync();
     var npgmq = new NpgmqClient(connection);
 
-    await using (var tx = connection.BeginTransaction())
+    await using (var tx = await connection.BeginTransactionAsync())
     {
         var msgId = await npgmq.SendAsync("example_queue", new MyMessageType
         {
             Foo = "Connection object test",
             Bar = 2
         });
         Console.WriteLine($"Sent message with id {msgId}");
+        msgId = await npgmq.SendAsync("example_queue", new MyMessageType
+        {
+            Foo = "Connection object test",
+            Bar = 3
+        });
+        Console.WriteLine($"Sent message with id {msgId}");
 
         await tx.CommitAsync();
     }
@@ -56,6 +62,12 @@
         Console.WriteLine($"Read message with id {msg.MsgId}: Foo = {msg.Message?.Foo}, Bar = {msg.Message?.Bar}");
         await npgmq.ArchiveAsync("example_queue", msg.MsgId);
     }
+    msg = await npgmq.ReadAsync<MyMessageType>("example_queue");
+    if (msg != null)
+    {
+        Console.WriteLine($"Read message with id {msg.MsgId}: Foo = {msg.Message?.Foo}, Bar = {msg.Message?.Bar}");
+        await npgmq.ArchiveAsync("example_queue", msg.MsgId);
+    }
 }
 
 internal class MyMessageType