@@ -138,7 +138,7 @@ SharedBuffer Commands::newPartitionMetadataRequest(const std::string& topic, uin
138138 CommandPartitionedTopicMetadata* partitionMetadata = cmd.mutable_partitionmetadata ();
139139 partitionMetadata->set_topic (topic);
140140 partitionMetadata->set_request_id (requestId);
141- const SharedBuffer buffer = writeMessageWithSize (cmd);
141+ SharedBuffer buffer = writeMessageWithSize (cmd);
142142 cmd.clear_partitionmetadata ();
143143 return buffer;
144144}
@@ -154,7 +154,7 @@ SharedBuffer Commands::newLookup(const std::string& topic, const bool authoritat
154154 lookup->set_authoritative (authoritative);
155155 lookup->set_request_id (requestId);
156156 lookup->set_advertised_listener_name (listenerName);
157- const SharedBuffer buffer = writeMessageWithSize (cmd);
157+ SharedBuffer buffer = writeMessageWithSize (cmd);
158158 cmd.clear_lookuptopic ();
159159 return buffer;
160160}
@@ -173,7 +173,7 @@ SharedBuffer Commands::newGetSchema(const std::string& topic, const std::string&
173173 getSchema->set_schema_version (version);
174174 }
175175
176- const SharedBuffer buffer = writeMessageWithSize (cmd);
176+ SharedBuffer buffer = writeMessageWithSize (cmd);
177177 cmd.clear_getschema ();
178178 return buffer;
179179}
@@ -186,7 +186,7 @@ SharedBuffer Commands::newConsumerStats(uint64_t consumerId, uint64_t requestId)
186186 CommandConsumerStats* consumerStats = cmd.mutable_consumerstats ();
187187 consumerStats->set_consumer_id (consumerId);
188188 consumerStats->set_request_id (requestId);
189- const SharedBuffer buffer = writeMessageWithSize (cmd);
189+ SharedBuffer buffer = writeMessageWithSize (cmd);
190190 cmd.clear_consumerstats ();
191191 return buffer;
192192}
@@ -618,7 +618,7 @@ SharedBuffer Commands::newGetLastMessageId(uint64_t consumerId, uint64_t request
618618 CommandGetLastMessageId* getLastMessageId = cmd.mutable_getlastmessageid ();
619619 getLastMessageId->set_consumer_id (consumerId);
620620 getLastMessageId->set_request_id (requestId);
621- const SharedBuffer buffer = writeMessageWithSize (cmd);
621+ SharedBuffer buffer = writeMessageWithSize (cmd);
622622 cmd.clear_getlastmessageid ();
623623 return buffer;
624624}
@@ -632,7 +632,7 @@ SharedBuffer Commands::newGetTopicsOfNamespace(const std::string& nsName,
632632 getTopics->set_namespace_ (nsName);
633633 getTopics->set_mode (static_cast <proto::CommandGetTopicsOfNamespace_Mode>(mode));
634634
635- const SharedBuffer buffer = writeMessageWithSize (cmd);
635+ SharedBuffer buffer = writeMessageWithSize (cmd);
636636 cmd.clear_gettopicsofnamespace ();
637637 return buffer;
638638}
0 commit comments