Github user arpadboda commented on a diff in the pull request:
https://github.com/apache/nifi-minifi-cpp/pull/448#discussion_r236150567
--- Diff: nanofi/include/cxx/CallbackProcessor.h ---
@@ -65,24 +67,19 @@ class CallbackProcessor : public core::Processor {
public:
- void setCallback(void *obj,std::function<void(core::ProcessSession*)>
ontrigger_callback) {
+ void setCallback(void *obj,std::function<void(core::ProcessSession*,
core::ProcessContext *context)> ontrigger_callback) {
objref_ = obj;
callback_ = ontrigger_callback;
}
// OnTrigger method, implemented by NiFi CallbackProcessor
- virtual void onTrigger(core::ProcessContext *context,
core::ProcessSession *session);
+ virtual void onTrigger(core::ProcessContext *context,
core::ProcessSession *session) override;
// Initialize, over write by NiFi CallbackProcessor
- virtual void initialize() {
- std::set<core::Relationship> relationships;
- core::Relationship Success("success", "description");
- relationships.insert(Success);
- setSupportedRelationships(relationships);
- }
+ virtual void initialize() override;
protected:
void *objref_;
- std::function<void(core::ProcessSession*)> callback_;
+ std::function<void(core::ProcessSession*, core::ProcessContext
*context)> callback_;
--- End diff --
Context is required in the callback to:
-Access content
-Access properties (not yet supported, but will be)
---
