| #include <chrono> | |
| #include <gtest/gtest.h> | |
| #include <thread> | |
| #include "rocketmq/MQMessageExt.h" | |
| TEST(MessageTest, testExpire) { | |
| auto expire_time_point = std::chrono::steady_clock::now() + std::chrono::milliseconds(300); | |
| std::this_thread::sleep_for(std::chrono::milliseconds(200)); | |
| EXPECT_TRUE(std::chrono::steady_clock::now() < expire_time_point); | |
| } |