| 27 | core::Relationship CallbackProcessor::Failure("failure", "Failed files (based on callback logic) are transferred to failure"); |
| 28 | |
| 29 | void CallbackProcessor::initialize() { |
| 30 | std::set<core::Relationship> relationships; |
| 31 | relationships.insert(Success); |
| 32 | relationships.insert(Failure); |
| 33 | setSupportedRelationships(relationships); |
| 34 | } |
| 35 | |
| 36 | void CallbackProcessor::onSchedule(core::ProcessContext *context, core::ProcessSessionFactory* /*sessionFactory*/){ |
| 37 | if(onschedule_callback_ != nullptr) { |
no test coverage detected