blob: 60b09091f9eb88d660c3d9f3dff0d8f8edb429f7 [file]
#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);
}