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) {