Github user arpadboda commented on a diff in the pull request:
https://github.com/apache/nifi-minifi-cpp/pull/421#discussion_r227361733
--- Diff: libminifi/include/capi/Plan.h ---
@@ -93,11 +95,50 @@ class ExecutionPlan {
next_ff_ = ptr;
}
+ static std::shared_ptr<core::Processor> createProcessor(const
std::string &processor_name, const std::string &name);
+
protected:
+ class FailureHandler {
+ public:
+ FailureHandler() {
+ callback_ = nullptr;
+ }
+ void setCallback(void (*onerror_callback)(const flow_file_record*)) {
+ callback_=onerror_callback;
+ }
+ void operator()(const processor_session* ps)
+ {
--- End diff --
Makes sense, but I'm not aware of all possible use-cases here, so let's
discuss before doing further implementation.
---
