[pulsar-client-cpp] branch main updated: Fix batch receive for C client unit test faied. (#272)

[xyz]

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

xyz pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git


The following commit(s) were added to refs/heads/main by this push:
     new 3e4f49a  Fix batch receive for C client unit test faied. (#272)
3e4f49a is described below

commit 3e4f49a74d505257ff58e331ba4e776ed706310f
Author: Baodi Shi <ba...@apache.org>
AuthorDate: Wed May 17 07:57:55 2023 +0800

    Fix batch receive for C client unit test faied. (#272)
---
 tests/c/c_ConsumerTest.cc | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/tests/c/c_ConsumerTest.cc b/tests/c/c_ConsumerTest.cc
index 1c64cba..d824c8f 100644
--- a/tests/c/c_ConsumerTest.cc
+++ b/tests/c/c_ConsumerTest.cc
@@ -46,8 +46,8 @@ static void batch_receive_callback(pulsar_result 
async_result, pulsar_messages_t
 
             char expected_str[128];
             snprintf(expected_str, sizeof(expected_str), "msg-%d", 10 + i);
-            printf("%d received: %s (%zd), expected: %s (%zd)\n", i, str, 
strlen(str), expected_str,
-                   strlen(expected_str));
+            printf("async batch %d received: %s (%zd), expected: %s (%zd)\n", 
i, str, strlen(str),
+                   expected_str, strlen(expected_str));
             ASSERT_EQ(strcmp(str, expected_str), 0);
             free(str);
         }
@@ -110,7 +110,6 @@ TEST(c_ConsumerTest, testBatchReceive) {
     std::future<pulsar_result> receive_future = receive_promise.get_future();
     struct batch_receive_ctx batch_receive_ctx = {consumer, &receive_promise, 
batch_receive_max_size};
     pulsar_consumer_batch_receive_async(consumer, batch_receive_callback, 
&batch_receive_ctx);
-    pulsar_client_close(client);
     ASSERT_EQ(pulsar_result_Ok, receive_future.get());
 
     pulsar_client_close(client);