File tree Expand file tree Collapse file tree 2 files changed +6
-4
lines changed
Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -153,7 +153,7 @@ void CouchbaseClusterService::onEnable() {
153153gsl::not_null<std::shared_ptr<CouchbaseClusterService>> CouchbaseClusterService::getFromProperty (const core::ProcessContext& context, const core::PropertyReference& property) {
154154 std::shared_ptr<CouchbaseClusterService> couchbase_cluster_service;
155155 if (auto connection_controller_name = context.getProperty (property)) {
156- couchbase_cluster_service = std::dynamic_pointer_cast<CouchbaseClusterService>(context.getControllerService (*connection_controller_name));
156+ couchbase_cluster_service = std::dynamic_pointer_cast<CouchbaseClusterService>(context.getControllerService (*connection_controller_name, context. getProcessorNode ()-> getUUID () ));
157157 }
158158 if (!couchbase_cluster_service) {
159159 throw minifi::Exception (ExceptionType::PROCESS_SCHEDULE_EXCEPTION, " Missing Couchbase Cluster Service" );
Original file line number Diff line number Diff line change @@ -41,7 +41,9 @@ struct ExpectedCallOptions {
4141
4242class PutCouchbaseKeyTestController : public TestController {
4343 public:
44- PutCouchbaseKeyTestController () {
44+ PutCouchbaseKeyTestController ()
45+ : controller_(std::make_unique<processors::PutCouchbaseKey>(" PutCouchbaseKey" )),
46+ proc_ (controller_.getProcessor()) {
4547 LogTestController::getInstance ().setDebug <TestPlan>();
4648 LogTestController::getInstance ().setDebug <minifi::core::Processor>();
4749 LogTestController::getInstance ().setTrace <minifi::core::ProcessSession>();
@@ -110,8 +112,8 @@ class PutCouchbaseKeyTestController : public TestController {
110112 }
111113
112114 protected:
113- std::shared_ptr<core::Processor> proc_ = std::make_shared<processors::PutCouchbaseKey>( " PutCouchbaseKey " ) ;
114- minifi::test::SingleProcessorTestController controller_{ proc_} ;
115+ minifi::test::SingleProcessorTestController controller_ ;
116+ core::Processor* proc_ = nullptr ;
115117 std::shared_ptr<MockCouchbaseClusterService> mock_couchbase_cluster_service_;
116118};
117119
You can’t perform that action at this time.
0 commit comments