lordgamez commented on code in PR #1990:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1990#discussion_r2254294128
##########
extensions/mqtt/processors/ConsumeMQTT.h:
##########
@@ -92,15 +107,26 @@ class ConsumeMQTT : public
processors::AbstractMQTTProcessor {
QueueBufferMaxMessage,
AttributeFromContentType,
TopicAliasMaximum,
- ReceiveMaximum
+ ReceiveMaximum,
+ RecordReader,
+ RecordWriter,
+ AddAttributesAsFields
}), AbstractMQTTProcessor::AdvancedProperties);
EXTENSIONAPI static constexpr auto Success =
core::RelationshipDefinition{"success", "FlowFiles that are sent successfully
to the destination are transferred to this relationship"};
EXTENSIONAPI static constexpr auto Relationships = std::array{Success};
EXTENSIONAPI static constexpr auto BrokerOutputAttribute =
core::OutputAttributeDefinition<0>{"mqtt.broker", {}, "URI of the sending
broker"};
EXTENSIONAPI static constexpr auto TopicOutputAttribute =
core::OutputAttributeDefinition<0>{"mqtt.topic", {}, "Topic of the message"};
- EXTENSIONAPI static constexpr auto OutputAttributes =
std::array<core::OutputAttributeReference, 2>{BrokerOutputAttribute,
TopicOutputAttribute};
+ EXTENSIONAPI static constexpr auto TopicSegmentOutputAttribute =
core::OutputAttributeDefinition<0>{"mqtt.topic.segment.n", {}, "The nth topic
segment of the message"};
+ EXTENSIONAPI static constexpr auto QosOutputAttribute =
core::OutputAttributeDefinition<0>{"mqtt.qos", {}, "The quality of service for
this message."};
+ EXTENSIONAPI static constexpr auto IsDuplicateOutputAttribute =
core::OutputAttributeDefinition<0>{"mqtt.isDuplicate", {},
+ "Whether or not this message might be a duplicate of one which has
already been received."};
+ EXTENSIONAPI static constexpr auto IsRetainedOutputAttribute =
core::OutputAttributeDefinition<0>{"mqtt.isRetained", {},
+ "Whether or not this message was from a current publisher, or was
\"retained\" by the server as the last message published on the topic."};
+ EXTENSIONAPI static constexpr auto RecordCountOutputAttribute =
core::OutputAttributeDefinition<0>{"record.count", {}, "The number of records
received"};
+ EXTENSIONAPI static constexpr auto OutputAttributes =
std::array<core::OutputAttributeReference, 7>{BrokerOutputAttribute,
TopicOutputAttribute, TopicSegmentOutputAttribute,
+ QosOutputAttribute, IsDuplicateOutputAttribute,
IsRetainedOutputAttribute, RecordCountOutputAttribute};
Review Comment:
Updated in
https://github.com/apache/nifi-minifi-cpp/pull/1990/commits/7e2cad557da32447caada0536e44ada143104195
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
