You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ph...@apache.org on 2018/01/10 10:59:13 UTC
nifi-minifi-cpp git commit: MINIFICPP-363 Allow for unqualified class
names in YAML configuration
Repository: nifi-minifi-cpp
Updated Branches:
refs/heads/master c6f9dc628 -> 0da444e9a
MINIFICPP-363 Allow for unqualified class names in YAML configuration
This closes #234.
Signed-off-by: Marc Parisi <ph...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/0da444e9
Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/0da444e9
Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/0da444e9
Branch: refs/heads/master
Commit: 0da444e9ace1bf8e75c919ecb94b2ee14c6613f9
Parents: c6f9dc6
Author: Andrew I. Christianson <an...@andyic.org>
Authored: Mon Jan 8 21:12:24 2018 -0500
Committer: Marc Parisi <ph...@apache.org>
Committed: Wed Jan 10 05:58:50 2018 -0500
----------------------------------------------------------------------
libminifi/src/core/yaml/YamlConfiguration.cpp | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/0da444e9/libminifi/src/core/yaml/YamlConfiguration.cpp
----------------------------------------------------------------------
diff --git a/libminifi/src/core/yaml/YamlConfiguration.cpp b/libminifi/src/core/yaml/YamlConfiguration.cpp
index 399124d..e749a77 100644
--- a/libminifi/src/core/yaml/YamlConfiguration.cpp
+++ b/libminifi/src/core/yaml/YamlConfiguration.cpp
@@ -112,6 +112,9 @@ void YamlConfiguration::parseProcessorNodeYaml(YAML::Node processorsNode, core::
int nameLength = procCfg.javaClass.length() - lastOfIdx;
std::string processorName = procCfg.javaClass.substr(lastOfIdx, nameLength);
processor = this->createProcessor(processorName, uuid);
+ } else {
+ // Allow unqualified class names for core processors
+ processor = this->createProcessor(procCfg.javaClass, uuid);
}
if (!processor) {