Github user arpadboda commented on a diff in the pull request:
https://github.com/apache/nifi-minifi-cpp/pull/404#discussion_r222249496
--- Diff: libminifi/src/capi/Plan.cpp ---
@@ -35,6 +36,41 @@
ExecutionPlan::ExecutionPlan(std::shared_ptr<core::ContentRepository> content_re
stream_factory =
org::apache::nifi::minifi::io::StreamFactory::getInstance(std::make_shared<minifi::Configure>());
}
+std::shared_ptr<core::Processor> ExecutionPlan::addCallback(void *obj,
void (*fp)(processor_session *)) {
+ if (finalized) {
+ return nullptr;
+ }
+
+ utils::Identifier uuid;
+ id_generator_->generate(uuid);
+
+ auto ptr =
core::ClassLoader::getDefaultClassLoader().instantiate("CallbackProcessor",
uuid);
+ if (nullptr == ptr) {
+ throw std::exception();
--- End diff --
Why don't we define a dedicated exception type for this?
---
