From 767250fd42774665f2ceffbd1406e8c55b251c76 Mon Sep 17 00:00:00 2001
From: Jiabei Zhao <970058803@qq.com>
Date: Mon, 9 Aug 2021 14:39:14 +0800
Subject: [PATCH] Use sendRequestWithId to add timeout to hasMessageAvailable

---
 pulsar-client-cpp/lib/ClientConnection.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client-cpp/lib/ClientConnection.cc b/pulsar-client-cpp/lib/ClientConnection.cc
index 47ab4f79bd0dc..8784cc98cb546 100644
--- a/pulsar-client-cpp/lib/ClientConnection.cc
+++ b/pulsar-client-cpp/lib/ClientConnection.cc
@@ -1582,7 +1582,7 @@ Future<Result, MessageId> ClientConnection::newGetLastMessageId(uint64_t consume
 
     pendingGetLastMessageIdRequests_.insert(std::make_pair(requestId, promise));
     lock.unlock();
-    sendCommand(Commands::newGetLastMessageId(consumerId, requestId));
+    sendRequestWithId(Commands::newGetLastMessageId(consumerId, requestId), requestId);
     return promise.getFuture();
 }