clang format

Author: zhanglistar

lib/ConsumerImpl.cc

@@ -1106,11 +1106,11 @@ Result ConsumerImpl::receiveHelper(Message& msg, int timeout) {
         }
         auto cnx = getCnx().lock();
         if (cnx) {
-            LOG_WARN(getName() << " Receive timeout after " << timeout << " ms, connection: " << cnx->cnxString()
-                              << ", queue size: " << incomingMessages_.size());
+            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());
+            LOG_WARN(getName() << " Receive timeout after " << timeout
+                               << " ms, no connection, queue size: " << incomingMessages_.size());
         }
         return ResultTimeout;
     }

lib/MultiTopicsConsumerImpl.cc

@@ -603,11 +603,11 @@ Result MultiTopicsConsumerImpl::receive(Message& msg, int timeout) {
         }
         auto cnx = getCnx().lock();
         if (cnx) {
-            LOG_WARN(getName() << " Receive timeout after " << timeout << " ms, connection: " << cnx->cnxString()
-                              << ", queue size: " << incomingMessages_.size());
+            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());
+            LOG_WARN(getName() << " Receive timeout after " << timeout
+                               << " ms, no connection, queue size: " << incomingMessages_.size());
         }
         return ResultTimeout;
     }

lib/UnAckedMessageTrackerEnabled.cc

@@ -60,13 +60,13 @@ void UnAckedMessageTrackerEnabled::timeoutHandlerHelper() {
     if (!headPartition.empty()) {
         auto cnx = consumerReference_.getCnx().lock();
         if (cnx) {
-            LOG_WARN(consumerReference_.getName() << " Unacked messages timeout: " << headPartition.size()
-                                                  << " messages not acked within " << timeoutMs_
-                                                  << " ms, connection: " << cnx->cnxString());
+            LOG_WARN(consumerReference_.getName()
+                     << " Unacked messages timeout: " << headPartition.size() << " messages not acked within "
+                     << timeoutMs_ << " ms, connection: " << cnx->cnxString());
         } else {
-            LOG_WARN(consumerReference_.getName() << " Unacked messages timeout: " << headPartition.size()
-                                                  << " messages not acked within " << timeoutMs_
-                                                  << " ms, no connection");
+            LOG_WARN(consumerReference_.getName()
+                     << " Unacked messages timeout: " << headPartition.size() << " messages not acked within "
+                     << timeoutMs_ << " ms, no connection");
         }
         for (auto it = headPartition.begin(); it != headPartition.end(); it++) {
             msgIdsToRedeliver.insert(*it);