This is an automated email from the ASF dual-hosted git repository.
otto pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
from 0c5d8de95a test(plc4go): exclude examples, tests and tools from
coverage
add 0c46213146 Feature/nifi integration record listener (#958)
No new revisions were added by this update.
Summary of changes:
plc4j/integrations/apache-nifi/README.md | 25 +-
.../apache-nifi/nifi-plc4x-processors/pom.xml | 26 +-
.../org/apache/plc4x/nifi/BasePlc4xProcessor.java | 24 +-
.../plc4x/nifi/Plc4xListenRecordProcessor.java | 301 +++++++++++++++++++++
.../org/apache/plc4x/nifi/Plc4xSinkProcessor.java | 6 +-
.../plc4x/nifi/Plc4xSinkRecordProcessor.java | 36 +--
.../apache/plc4x/nifi/Plc4xSourceProcessor.java | 5 +-
.../plc4x/nifi/Plc4xSourceRecordProcessor.java | 28 +-
.../nifi/record/Plc4xReadResponseRecordSet.java | 53 +++-
.../plc4x/nifi/record/RecordPlc4xWriter.java | 26 +-
.../org/apache/plc4x/nifi/record/SchemaCache.java | 2 +-
.../nifi/subscription/Plc4xListenerDispatcher.java | 153 +++++++++++
.../nifi/subscription/Plc4xSubscriptionType.java | 15 +-
.../services/org.apache.nifi.processor.Processor | 3 +-
...st.java => Plc4xListenRecordProcessorTest.java} | 24 +-
.../apache/plc4x/nifi/Plc4xSinkProcessorTest.java | 1 +
.../plc4x/nifi/Plc4xSinkRecordProcessorTest.java | 2 +-
.../plc4x/nifi/Plc4xSourceProcessorTest.java | 1 +
.../plc4x/nifi/Plc4xSourceRecordProcessorTest.java | 2 +-
plc4j/integrations/apache-nifi/pom.xml | 52 ++--
20 files changed, 631 insertions(+), 154 deletions(-)
create mode 100644
plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/Plc4xListenRecordProcessor.java
create mode 100644
plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/subscription/Plc4xListenerDispatcher.java
copy plc4c/drivers/modbus/src/driver_modbus_static.c =>
plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/subscription/Plc4xSubscriptionType.java
(73%)
copy
plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/test/java/org/apache/plc4x/nifi/{Plc4xSourceRecordProcessorTest.java
=> Plc4xListenRecordProcessorTest.java} (77%)
