Method onSchedule

extensions/sql/processors/SQLProcessor.h:42–51

  }

  void onSchedule(const std::shared_ptr<core::ProcessContext>& context, const std::shared_ptr<core::ProcessSessionFactory>& sessionFactory) override {
    std::string controllerService;
    context->getProperty(dbControllerService().getName(), controllerService);

    dbService_ = std::dynamic_pointer_cast<sql::controllers::DatabaseService>(context->getControllerService(controllerService));
    if (!dbService_)
      throw minifi::Exception(PROCESSOR_EXCEPTION, "'DB Controller Service' must be defined");

    static_cast<T*>(this)->processOnSchedule(*context);
  }

  void onTrigger(const std::shared_ptr<core::ProcessContext>& context, const std::shared_ptr<core::ProcessSession>& session) override {
    std::unique_lock<std::mutex> lock(onTriggerMutex_, std::try_to_lock);