Skip to content

Commit 3744b21

Browse files
committed
fix test
1 parent 51b9016 commit 3744b21

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tests/BasicEndToEndTest.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3978,7 +3978,7 @@ TEST(BasicEndToEndTest, testAckGroupingTrackerEnabledCumulativeAck) {
39783978
clientImplPtr->getIOExecutorProvider()->get());
39793979
tracker1->start(std::static_pointer_cast<HandlerBase>(PulsarFriend::getConsumerImplPtr(consumer)));
39803980
tracker1->addAcknowledgeCumulative(recvMsgId[numMsg - 1], nullptr);
3981-
tracker1.reset();
3981+
tracker1->flushAndClean();
39823982
consumer.close();
39833983

39843984
ASSERT_EQ(ResultOk, client.subscribe(topicName, subName, consumer));

0 commit comments

Comments
 (0)