QuanticPony commented on code in PR #809:
URL: https://github.com/apache/plc4x/pull/809#discussion_r1113977993
##########
plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/Plc4xSinkProcessor.java:
##########
@@ -64,12 +67,13 @@ public void onTrigger(final ProcessContext context, final
ProcessSession session
if (tags != null){
for (Map.Entry<String,PlcTag> tag : tags.entrySet()){
- builder.addTag(tag.getKey(), tag.getValue());
+ builder.addTag(tag.getKey(), tag.getValue(),
flowFile.getAttribute(tag.getKey()));
Review Comment:
This flowfile's attribute is the value we need to write into the Plc. I
forgot including this on the previous PR.
I have added a check to see if it is present. Similar to
Plc4xSinkRecordProcessor and record fields.
--
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: dev-unsubscr...@plc4x.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
