diff --git a/csharp/examples/ProducerDelayMessageExample.cs b/csharp/examples/ProducerDelayMessageExample.cs index 83f048aa6..fa3d4baed 100644 --- 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(); } } } \ No newline at end of file diff --git a/csharp/examples/ProducerFifoMessageExample.cs b/csharp/examples/ProducerFifoMessageExample.cs index c2fbef2cd..bba5fc609 100644 --- 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(); } } } \ No newline at end of file diff --git a/csharp/examples/ProducerNormalMessageExample.cs b/csharp/examples/ProducerNormalMessageExample.cs index 10ec74708..c94662d0f 100644 --- 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(); } } } \ No newline at end of file diff --git a/csharp/examples/ProducerTransactionMessageExample.cs b/csharp/examples/ProducerTransactionMessageExample.cs index 570ee35c8..ebaec134b 100644 --- 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(); } } } \ No newline at end of file diff --git a/csharp/examples/QuickStart.cs b/csharp/examples/QuickStart.cs index 2d4a674df..1bbdebdec 100644 --- 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 index 206e93718..221ce05a0 100644 --- 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(); } } } \ No newline at end of file