[fix][client] Fix clang-format violations in ConsumerImpl and MessageChunkingTest

Author: geniusjoe

lib/ConsumerImpl.cc

@@ -627,17 +627,17 @@ optional<SharedBuffer> ConsumerImpl::processMessageChunk(const SharedBuffer& pay
                          << uuid << ", messageId: " << messageId);
                 acknowledgeAsync(messageId, [uuid, messageId](Result result) {
                     if (result != ResultOk) {
-                        LOG_WARN("Failed to acknowledge duplicated chunk, uuid: "
-                                 << uuid << ", messageId: " << messageId);
+                        LOG_WARN("Failed to acknowledge duplicated chunk, uuid: " << uuid << ", messageId: "
+                                                                                  << messageId);
                     }
                 });
             }
             return {};
         }
         // chunkId > lastChunkedMessageId + 1, the chunked message is corrupted.
-        LOG_WARN("Received unexpected chunk (uuid: "
-                 << uuid << " chunkId: " << chunkId << ", lastChunkedMessageId: " << lastChunkedMessageId
-                 << ", messageId: " << messageId << ")");
+        LOG_WARN("Received unexpected chunk (uuid: " << uuid << " chunkId: " << chunkId
+                                                     << ", lastChunkedMessageId: " << lastChunkedMessageId
+                                                     << ", messageId: " << messageId << ")");
         chunkedMessageCache_.remove(uuid);
         // If this is the last chunk, its permit was not returned at the entry of processMessageChunk,
         // so we need to return it here to avoid permit leak.
@@ -648,8 +648,8 @@ optional<SharedBuffer> ConsumerImpl::processMessageChunk(const SharedBuffer& pay
         if (expireTimeOfIncompleteChunkedMessageMs_ > 0 &&
             TimeUtils::currentTimeMillis() >
                 static_cast<long>(metadata.publish_time()) + expireTimeOfIncompleteChunkedMessageMs_) {
-            LOG_INFO("Acking corrupted gap chunk to avoid ack hole, uuid: "
-                     << uuid << ", messageId: " << messageId);
+            LOG_INFO("Acking corrupted gap chunk to avoid ack hole, uuid: " << uuid
+                                                                            << ", messageId: " << messageId);
             acknowledgeAsync(messageId, [uuid, messageId](Result result) {
                 if (result != ResultOk) {
                     LOG_WARN("Failed to acknowledge gap chunk, uuid: " << uuid

tests/MessageChunkingTest.cc

@@ -338,8 +338,8 @@ TEST_P(MessageChunkingTest, testResendChunkMessagesWithoutAckHole) {
     if (toString(GetParam()) != "None") {
         return;
     }
-    const std::string topic = "MessageChunkingTest-testResendChunkMessagesWithoutAckHole-" +
-                              std::to_string(time(nullptr));
+    const std::string topic =
+        "MessageChunkingTest-testResendChunkMessagesWithoutAckHole-" + std::to_string(time(nullptr));
     Consumer consumer;
     ConsumerConfiguration consumerConf;
     consumerConf.setMaxPendingChunkedMessage(10);
@@ -379,8 +379,7 @@ TEST_P(MessageChunkingTest, testResendChunkMessages) {
     if (toString(GetParam()) != "None") {
         return;
     }
-    const std::string topic =
-        "MessageChunkingTest-testResendChunkMessages-" + std::to_string(time(nullptr));
+    const std::string topic = "MessageChunkingTest-testResendChunkMessages-" + std::to_string(time(nullptr));
     Consumer consumer;
     ConsumerConfiguration consumerConf;
     consumerConf.setMaxPendingChunkedMessage(10);