[rocketmq-client-csharp] branch observability updated: WIP: Unit tests for SimpleConsumer.Receive

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch observability
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-csharp.git


The following commit(s) were added to refs/heads/observability by this push:
     new 9dd52d5  WIP: Unit tests for SimpleConsumer.Receive
9dd52d5 is described below

commit 9dd52d5074fd5d32abab4277286734a7cf91dabb
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Mon Jun 27 15:54:51 2022 +0800

    WIP: Unit tests for SimpleConsumer.Receive
---
 rocketmq-client-csharp/ClientManager.cs |  5 +++++
 tests/ProducerTest.cs                   | 27 +++++++++++++++++++++++++++
 tests/SimpleConsumerTest.cs             |  2 +-
 3 files changed, 33 insertions(+), 1 deletion(-)

diff --git a/rocketmq-client-csharp/ClientManager.cs b/rocketmq-client-csharp/ClientManager.cs
index f786a05..a39a0e0 100644
--- a/rocketmq-client-csharp/ClientManager.cs
+++ b/rocketmq-client-csharp/ClientManager.cs
@@ -191,6 +191,11 @@ namespace Org.Apache.Rocketmq
                                 Logger.Warn("TooManyRequest: servers throttled");
                                 break;
                             }
+                            default:
+                            {
+                                Logger.Warn("Unknown error status");
+                                break;
+                            }
                         }
                         break;
                     }
diff --git a/tests/ProducerTest.cs b/tests/ProducerTest.cs
index 13d1712..663980a 100644
--- a/tests/ProducerTest.cs
+++ b/tests/ProducerTest.cs
@@ -79,6 +79,33 @@ namespace tests
             await producer.Shutdown();
         }
         
+        [TestMethod]
+        public async Task TestSendMultipleMessages()
+        {
+            var producer = new Producer(_accessPoint, resourceNamespace);
+            producer.CredentialsProvider = new ConfigFileCredentialsProvider();
+            producer.Region = "cn-hangzhou-pre";
+            await producer.Start();
+            byte[] body = new byte[1024];
+            Array.Fill(body, (byte)'x');
+            for (var i = 0; i < 128; i++)
+            {
+                var msg = new Message(topic, body);
+            
+                // Tag the massage. A message has at most one tag.
+                msg.Tag = "Tag-0";
+            
+                // Associate the message with one or multiple keys
+                var keys = new List<string>();
+                keys.Add("k1");
+                keys.Add("k2");
+                msg.Keys = keys;
+                var sendResult = await producer.Send(msg);
+                Assert.IsNotNull(sendResult);                
+            }
+            await producer.Shutdown();
+        }
+        
         [TestMethod]
         public async Task TestSendFifoMessage()
         {
diff --git a/tests/SimpleConsumerTest.cs b/tests/SimpleConsumerTest.cs
index ee19c5e..2500503 100644
--- a/tests/SimpleConsumerTest.cs
+++ b/tests/SimpleConsumerTest.cs
@@ -64,7 +64,7 @@ namespace tests
             var batchSize = 32;
             var receiveTimeout = TimeSpan.FromSeconds(10);
             var messages  = await simpleConsumer.Receive(batchSize, receiveTimeout);
-            Console.WriteLine($"{messages}");
+            Console.WriteLine($"Received {messages.Count} messages in all");
             await simpleConsumer.Shutdown();
         }
     }