Skip to content

Commit 5b7f57c

Browse files
shibdBewareMyPower
andauthored
Apply suggestions from code review
Co-authored-by: Yunze Xu <[email protected]>
1 parent 5f2058e commit 5b7f57c

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

tests/ConsumerTest.cc

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1535,7 +1535,6 @@ TEST(ConsumerTest, testConsumerListenerShouldNotSegfaultAfterClose) {
15351535
Message message = MessageBuilder().setContent(msg).build();
15361536
ASSERT_EQ(ResultOk, producer.send(message));
15371537
}
1538-
ASSERT_EQ(ResultOk, producer.flush());
15391538

15401539
// 2. Create consumer with listener
15411540
Consumer consumer;
@@ -1546,7 +1545,7 @@ TEST(ConsumerTest, testConsumerListenerShouldNotSegfaultAfterClose) {
15461545
consumerConfig.setMessageListener(
15471546
[&latchFirstReceiveMsg, &latchAfterClosed](Consumer consumer, const Message& msg) {
15481547
latchFirstReceiveMsg.countdown();
1549-
std::cout << "Consume message: " << msg.getDataAsString() << std::endl;
1548+
LOG_INFO("Consume message: " << msg.getDataAsString());
15501549
latchAfterClosed.wait();
15511550
});
15521551
auto result = client.subscribe(topicName, "test-sub", consumerConfig, consumer);

0 commit comments

Comments
 (0)