Method addConnection

libminifi/test/TestBase.cpp:162–181

}

std::shared_ptr<minifi::Connection> TestPlan::addConnection(const std::shared_ptr<core::Processor>& source_proc, const core::Relationship& source_relationship, const std::shared_ptr<core::Processor>& destination_proc) {
  std::stringstream connection_name;
  connection_name << source_proc->getUUIDStr() << "-to-" << destination_proc->getUUIDStr();
  std::shared_ptr<minifi::Connection> connection = std::make_shared<minifi::Connection>(flow_repo_, content_repo_, connection_name.str());

  connection->addRelationship(source_relationship);

  // link the connections so that we can test results at the end for this
  connection->setSource(source_proc);
  connection->setDestination(destination_proc);

  connection->setSourceUUID(source_proc->getUUID());
  connection->setDestinationUUID(destination_proc->getUUID());
  source_proc->addConnection(connection);
  if (source_proc != destination_proc) {
    destination_proc->addConnection(connection);
  }
  relationships_.push_back(connection);
  return connection;
}

std::shared_ptr<core::controller::ControllerServiceNode> TestPlan::addController(const std::string &controller_name, const std::string &name) {
  if (finalized) {