format

Author: zhanglistar

lib/ConsumerImpl.cc

@@ -190,7 +190,8 @@ ConsumerImpl::~ConsumerImpl() {
         if (client) {
             LOG_WARN(consumerStr_ << "Destroyed consumer which was not properly closed");
         } else {
-            LOG_DEBUG(consumerStr_ << "Destroyed consumer which was not properly closed (client already destroyed)");
+            LOG_DEBUG(consumerStr_
+                      << "Destroyed consumer which was not properly closed (client already destroyed)");
         }
 
         ClientConnectionPtr cnx = getCnx().lock();

lib/ProducerImpl.cc

@@ -122,7 +122,8 @@ ProducerImpl::~ProducerImpl() {
         if (client) {
             LOG_WARN(producerStr_ << "Destroyed producer which was not properly closed");
         } else {
-            LOG_DEBUG(producerStr_ << "Destroyed producer which was not properly closed (client already destroyed)");
+            LOG_DEBUG(producerStr_
+                      << "Destroyed producer which was not properly closed (client already destroyed)");
         }
     }
 }
@@ -759,7 +760,7 @@ void ProducerImpl::sendMessage(std::unique_ptr<OpSendMsg> opSendMsg) {
 void ProducerImpl::printStats() {
     if (batchMessageContainer_) {
         LOG_DEBUG("Producer - " << producerStr_ << ", [batchMessageContainer = " << *batchMessageContainer_
-                               << "]");
+                                << "]");
     } else {
         LOG_DEBUG("Producer - " << producerStr_ << ", [batching  = off]");
     }