chore: remove unnecessary WARN logs for send or receive timeouts

Author: BewareMyPower

lib/ConsumerImpl.cc

@@ -1117,14 +1117,6 @@ Result ConsumerImpl::receiveHelper(Message& msg, int timeout) {
         if (state_ != Ready) {
             return ResultAlreadyClosed;
         }
-        auto cnx = getCnx().lock();
-        if (cnx) {
-            LOG_WARN(getName() << " Receive timeout after " << timeout << " ms, connection: "
-                               << cnx->cnxString() << ", queue size: " << incomingMessages_.size());
-        } else {
-            LOG_WARN(getName() << " Receive timeout after " << timeout
-                               << " ms, no connection, queue size: " << incomingMessages_.size());
-        }
         return ResultTimeout;
     }
 }

lib/MultiTopicsConsumerImpl.cc

@@ -603,14 +603,6 @@ Result MultiTopicsConsumerImpl::receive(Message& msg, int timeout) {
         if (state_ != Ready) {
             return ResultAlreadyClosed;
         }
-        auto cnx = getCnx().lock();
-        if (cnx) {
-            LOG_WARN(getName() << " Receive timeout after " << timeout << " ms, connection: "
-                               << cnx->cnxString() << ", queue size: " << incomingMessages_.size());
-        } else {
-            LOG_WARN(getName() << " Receive timeout after " << timeout
-                               << " ms, no connection, queue size: " << incomingMessages_.size());
-        }
         return ResultTimeout;
     }
 }

lib/ProducerImpl.cc

@@ -873,6 +873,9 @@ void ProducerImpl::handleSendTimeout(const ASIO_ERROR& err) {
     }
 
     lock.unlock();
+    if (pendingMessages.empty()) {
+        return;
+    }
     auto cnx = getCnx().lock();
     if (cnx) {
         LOG_WARN(getName() << "Send timeout due to queueing delay, connection: " << cnx->cnxString()