commit 144de699415760eaa72bd9a8dce64e0b3027d4e1
author yulangz <53958801+yulangz@users.noreply.github.com> Sun Oct 08 23:09:27 2023 +0800
committer GitHub <noreply@github.com> Sun Oct 08 23:09:27 2023 +0800
tree b31486acda7e1818a9157dbdffd5622a25809f86
parent da39ef79838d56a1880083ce8e3fe7bd6660b94f

Fix the method of setting timestamp for Delay Producer. Before fixing, it may appear that the Message Type cannot be recognized as DELAY by the server, but rather as NORMAL. (#543)

Co-authored-by: htaowang <htaowang@tencent.com>

cpp/examples/ExampleProducerWithTimedMessage.cpp

diff --git a/cpp/examples/ExampleProducerWithTimedMessage.cpp b/cpp/examples/ExampleProducerWithTimedMessage.cpp
index c462385..8f12f5b 100644
--- a/cpp/examples/ExampleProducerWithTimedMessage.cpp
+++ b/cpp/examples/ExampleProducerWithTimedMessage.cpp
@@ -77,6 +77,7 @@
                                              .withCredentialsProvider(credentials_provider)
                                              .withSsl(true)
                                              .build())
+                      .withTopics({FLAGS_topic})
                       .build();
 
   std::atomic_bool stopped;

cpp/source/rocketmq/ProducerImpl.cpp

diff --git a/cpp/source/rocketmq/ProducerImpl.cpp b/cpp/source/rocketmq/ProducerImpl.cpp
index a56d803..32b2eca 100644
--- a/cpp/source/rocketmq/ProducerImpl.cpp
+++ b/cpp/source/rocketmq/ProducerImpl.cpp
@@ -148,6 +148,9 @@
     if (delivery_timestamp.time_since_epoch().count()) {
       auto duration = delivery_timestamp.time_since_epoch();
       system_properties->set_delivery_attempt(std::chrono::duration_cast<std::chrono::milliseconds>(duration).count());
+      auto mutable_delivery_timestamp = system_properties->mutable_delivery_timestamp();
+      mutable_delivery_timestamp->set_seconds(std::chrono::duration_cast<std::chrono::seconds>(duration).count());
+      mutable_delivery_timestamp->set_nanos(std::chrono::duration_cast<std::chrono::nanoseconds>(duration).count() % 1000000000);
     }
   }