| 132 | } |
| 133 | |
| 134 | standalone_processor * create_processor(const char *name, nifi_instance * instance) { |
| 135 | NULL_CHECK(nullptr, name); |
| 136 | auto ptr = ExecutionPlan::createProcessor(name, name); |
| 137 | if (!ptr) { |
| 138 | return nullptr; |
| 139 | } |
| 140 | if (instance == NULL) { |
| 141 | nifi_port port; |
| 142 | auto port_str = utils::IdGenerator::getIdGenerator()->generate().to_string(); |
| 143 | port.port_id = const_cast<char*>(port_str.c_str()); |
| 144 | instance = create_instance("internal_standalone", &port); |
| 145 | } |
| 146 | auto flow = create_new_flow(instance); |
| 147 | std::shared_ptr<ExecutionPlan> plan(flow); |
| 148 | plan->addProcessor(ptr, name); |
| 149 | ExecutionPlan::addProcessorWithPlan(ptr->getUUID(), plan); |
| 150 | return static_cast<standalone_processor*>(ptr.get()); |
| 151 | } |
| 152 | |
| 153 | void initialize_content_repo(processor_context * ctx, const char * uuid) { |
| 154 | if (ctx->isInitialized()) { |