Skip to content

Commit 3e4f49a

Browse files
authored
Fix batch receive for C client unit test faied. (#272)
1 parent 49d9f18 commit 3e4f49a

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

tests/c/c_ConsumerTest.cc

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,8 @@ static void batch_receive_callback(pulsar_result async_result, pulsar_messages_t
4646

4747
char expected_str[128];
4848
snprintf(expected_str, sizeof(expected_str), "msg-%d", 10 + i);
49-
printf("%d received: %s (%zd), expected: %s (%zd)\n", i, str, strlen(str), expected_str,
50-
strlen(expected_str));
49+
printf("async batch %d received: %s (%zd), expected: %s (%zd)\n", i, str, strlen(str),
50+
expected_str, strlen(expected_str));
5151
ASSERT_EQ(strcmp(str, expected_str), 0);
5252
free(str);
5353
}
@@ -110,7 +110,6 @@ TEST(c_ConsumerTest, testBatchReceive) {
110110
std::future<pulsar_result> receive_future = receive_promise.get_future();
111111
struct batch_receive_ctx batch_receive_ctx = {consumer, &receive_promise, batch_receive_max_size};
112112
pulsar_consumer_batch_receive_async(consumer, batch_receive_callback, &batch_receive_ctx);
113-
pulsar_client_close(client);
114113
ASSERT_EQ(pulsar_result_Ok, receive_future.get());
115114

116115
pulsar_client_close(client);

0 commit comments

Comments
 (0)