| 58 | |
| 59 | core::Relationship ExecuteJavaProcessor::Success("success", "All files are routed to success"); |
| 60 | void ExecuteJavaProcessor::initialize() { |
| 61 | logger_->log_info("Initializing ExecuteJavaClass"); |
| 62 | // Set the supported properties |
| 63 | std::set<core::Property> properties; |
| 64 | properties.insert(JVMControllerService); |
| 65 | properties.insert(NiFiProcessor); |
| 66 | setSupportedProperties(properties); |
| 67 | setAcceptAllProperties(); |
| 68 | // Set the supported relationships |
| 69 | std::set<core::Relationship> relationships; |
| 70 | relationships.insert(Success); |
| 71 | setSupportedRelationships(relationships); |
| 72 | } |
| 73 | |
| 74 | void ExecuteJavaProcessor::onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) { |
| 75 | std::string controller_service_name; |