This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch cpp
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/cpp by this push:
     new 4acf0f0  Fix builds on Windows
4acf0f0 is described below

commit 4acf0f0a331ba6a92fb1da72c9ad1250f26833c3
Author: Li Zhanhui <[email protected]>
AuthorDate: Mon Jul 4 13:03:13 2022 +0800

    Fix builds on Windows
---
 cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp 
b/cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp
index 9dc38ed..1761811 100644
--- a/cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp
+++ b/cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp
@@ -28,7 +28,7 @@
 #include "PushConsumerImpl.h"
 #include "ReceiveMessageResult.h"
 #include "Signature.h"
-#include "include/AsyncReceiveMessageCallback.h"
+#include "AsyncReceiveMessageCallback.h"
 #include "rocketmq/MessageListener.h"
 
 using namespace std::chrono;
@@ -111,7 +111,7 @@ void ProcessQueueImpl::popMessage() {
   syncIdleState();
   SPDLOG_DEBUG("Try to pop message from {}", simpleNameOf(message_queue_));
 
-  std::weak_ptr<AsyncReceiveMessageCallback> cb{receive_callback_};
+  std::weak_ptr<AsyncReceiveMessageCallback> cb(receive_callback_);
   auto callback = [cb](const std::error_code& ec, const ReceiveMessageResult& 
result) {
     std::shared_ptr<AsyncReceiveMessageCallback> recv_cb = cb.lock();
     if (recv_cb) {

Reply via email to