[GitHub] [nifi-minifi-cpp] szaszm commented on a change in pull request #1083: MINIFICPP-1507 convert OutputStream::write to size_t

[GitBox]

szaszm commented on a change in pull request #1083:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1083#discussion_r649404073



##########
File path: extensions/mqtt/processors/ConsumeMQTT.h
##########
@@ -80,10 +81,13 @@ class ConsumeMQTT : public 
processors::AbstractMQTTProcessor {
     }
     MQTTClient_message *message_;
     int64_t process(const std::shared_ptr<io::BaseStream>& stream) {
-      int64_t len = 
stream->write(reinterpret_cast<uint8_t*>(message_->payload), 
message_->payloadlen);
-      if (len < 0)
+      if (message_->payloadlen < 0) return -1;

Review comment:
       Yes, good catch. Done in 4195052.




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org