You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2023/03/17 06:21:44 UTC
[rocketmq-clients] 01/02: Polish the example
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 <ya...@gmail.com>
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