Polish the example

apache · Mar 17, 2023 · 18ff64d · 18ff64d
1 parent 2234f70
commit 18ff64d
Show file tree

Hide file tree

Showing 6 changed files with 25 additions and 17 deletions.
diff --git a/csharp/examples/ProducerDelayMessageExample.cs b/csharp/examples/ProducerDelayMessageExample.cs
@@ -66,8 +66,9 @@ internal static async Task QuickStart()
 
             var sendReceipt = await producer.Send(message);
             Logger.Info($"Send message successfully, sendReceipt={sendReceipt}");
-            // Or you could close the producer manually.
-            // await producer.DisposeAsync();
+
+            // Close the producer if you don't need it anymore.
+            await producer.DisposeAsync();
         }
     }
 }
diff --git a/csharp/examples/ProducerFifoMessageExample.cs b/csharp/examples/ProducerFifoMessageExample.cs
@@ -68,9 +68,9 @@ internal static async Task QuickStart()
 
             var sendReceipt = await producer.Send(message);
             Logger.Info($"Send message successfully, sendReceipt={sendReceipt}");
-            Thread.Sleep(9999999);
-            // Or you could close the producer manually.
-            // await producer.DisposeAsync();
+
+            // Close the producer if you don't need it anymore.
+            await producer.DisposeAsync();
         }
     }
 }
diff --git a/csharp/examples/ProducerNormalMessageExample.cs b/csharp/examples/ProducerNormalMessageExample.cs
@@ -65,8 +65,8 @@ internal static async Task QuickStart()
             var sendReceipt = await producer.Send(message);
             Logger.Info($"Send message successfully, messageId={sendReceipt.MessageId}");
 
-            // Or you could close the producer manually.
-            // await producer.DisposeAsync();
+            // Close the producer if you don't need it anymore.
+            await producer.DisposeAsync();
         }
     }
 }
diff --git a/csharp/examples/ProducerTransactionMessageExample.cs b/csharp/examples/ProducerTransactionMessageExample.cs
@@ -79,8 +79,9 @@ internal static async Task QuickStart()
             transaction.Commit();
             // Or rollback the transaction.
             // transaction.Rollback();
-            // Or you could close the producer manually.
-            // await producer.DisposeAsync();
+
+            // Close the producer if you don't need it anymore.
+            await producer.DisposeAsync();
         }
     }
 }
diff --git a/csharp/examples/QuickStart.cs b/csharp/examples/QuickStart.cs
@@ -21,7 +21,7 @@ internal static class QuickStart
     {
         public static void Main()
         {
-            // ProducerNormalMessageExample.QuickStart().Wait();
+            ProducerNormalMessageExample.QuickStart().Wait();
             // ProducerFifoMessageExample.QuickStart().Wait();
             // ProducerDelayMessageExample.QuickStart().Wait();
             // ProducerTransactionMessageExample.QuickStart().Wait();

diff --git a/csharp/examples/SimpleConsumerExample.cs b/csharp/examples/SimpleConsumerExample.cs
@@ -55,15 +55,21 @@ internal static async Task QuickStart()
                 .SetSubscriptionExpression(subscription)
                 .Build();
 
-            var messageViews = await simpleConsumer.Receive(16, TimeSpan.FromSeconds(15));
-            foreach (var message in messageViews)
+            while (true)
             {
-                Logger.Info($"Received a message, topic={message.Topic}, message-id={message.MessageId}, body-size={message.Body.Length}");
-                await simpleConsumer.Ack(message);
-                Logger.Info($"Message is acknowledged successfully, message-id={message.MessageId}");
-                // await simpleConsumer.ChangeInvisibleDuration(message, TimeSpan.FromSeconds(15));
-                // Logger.Info($"Changing message invisible duration successfully, message=id={message.MessageId}");
+                var messageViews = await simpleConsumer.Receive(16, TimeSpan.FromSeconds(15));
+                foreach (var message in messageViews)
+                {
+                    Logger.Info(
+                        $"Received a message, topic={message.Topic}, message-id={message.MessageId}, body-size={message.Body.Length}");
+                    await simpleConsumer.Ack(message);
+                    Logger.Info($"Message is acknowledged successfully, message-id={message.MessageId}");
+                    // await simpleConsumer.ChangeInvisibleDuration(message, TimeSpan.FromSeconds(15));
+                    // Logger.Info($"Changing message invisible duration successfully, message=id={message.MessageId}");
+                }
             }
+            // Close the simple consumer if you don't need it anymore.
+            // await simpleConsumer.DisposeAsync();
         }
     }
 }