This is an automated email from the ASF dual-hosted git repository. aaronai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 18ff64d936551133e5a944ff13508d56beeed1e1 Author: Aaron Ai <[email protected]> AuthorDate: Fri Mar 17 14:07:52 2023 +0800 Polish the example --- csharp/examples/ProducerDelayMessageExample.cs | 5 +++-- csharp/examples/ProducerFifoMessageExample.cs | 6 +++--- csharp/examples/ProducerNormalMessageExample.cs | 4 ++-- csharp/examples/ProducerTransactionMessageExample.cs | 5 +++-- csharp/examples/QuickStart.cs | 2 +- csharp/examples/SimpleConsumerExample.cs | 20 +++++++++++++------- 6 files changed, 25 insertions(+), 17 deletions(-) diff --git a/csharp/examples/ProducerDelayMessageExample.cs b/csharp/examples/ProducerDelayMessageExample.cs index 83f048aa..fa3d4bae 100644 --- a/csharp/examples/ProducerDelayMessageExample.cs +++ b/csharp/examples/ProducerDelayMessageExample.cs @@ -66,8 +66,9 @@ namespace examples 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 c2fbef2c..bba5fc60 100644 --- a/csharp/examples/ProducerFifoMessageExample.cs +++ b/csharp/examples/ProducerFifoMessageExample.cs @@ -68,9 +68,9 @@ namespace examples 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 10ec7470..c94662d0 100644 --- a/csharp/examples/ProducerNormalMessageExample.cs +++ b/csharp/examples/ProducerNormalMessageExample.cs @@ -65,8 +65,8 @@ namespace examples 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 570ee35c..ebaec134 100644 --- a/csharp/examples/ProducerTransactionMessageExample.cs +++ b/csharp/examples/ProducerTransactionMessageExample.cs @@ -79,8 +79,9 @@ namespace examples 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 2d4a674d..1bbdebde 100644 --- a/csharp/examples/QuickStart.cs +++ b/csharp/examples/QuickStart.cs @@ -21,7 +21,7 @@ namespace examples { 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 206e9371..221ce05a 100644 --- a/csharp/examples/SimpleConsumerExample.cs +++ b/csharp/examples/SimpleConsumerExample.cs @@ -55,15 +55,21 @@ namespace examples .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
