MINIFI-279: Makes test classes naming consistent.
This closes #82.
Signed-off-by: Aldrin Piri <aldrin@apache.org>
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/TestConfigurationChangeCoordinator.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinatorTest.java
similarity index 98%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/TestConfigurationChangeCoordinator.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinatorTest.java
index a6882a5..ad16f72 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/TestConfigurationChangeCoordinator.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinatorTest.java
@@ -32,7 +32,7 @@
import static org.mockito.Mockito.verify;
-public class TestConfigurationChangeCoordinator {
+public class ConfigurationChangeCoordinatorTest {
private ConfigurationChangeCoordinator coordinatorSpy;
private Properties properties = new Properties();
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/TestWholeConfigDifferentiator.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/WholeConfigDifferentiatorTest.java
similarity index 98%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/TestWholeConfigDifferentiator.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/WholeConfigDifferentiatorTest.java
index 9dabea3..d2115a2 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/TestWholeConfigDifferentiator.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/differentiators/WholeConfigDifferentiatorTest.java
@@ -39,7 +39,7 @@
import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.when;
-public class TestWholeConfigDifferentiator {
+public class WholeConfigDifferentiatorTest {
public static final Path newConfigPath = Paths.get("./src/test/resources/config.yml");
public static final Path defaultConfigPath = Paths.get("./src/test/resources/default.yml");
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestFileChangeIngestor.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/FileChangeIngestorTest.java
similarity index 99%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestFileChangeIngestor.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/FileChangeIngestorTest.java
index 9817e7e..7cac488 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestFileChangeIngestor.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/FileChangeIngestorTest.java
@@ -39,7 +39,7 @@
import org.junit.Test;
import org.mockito.Mockito;
-public class TestFileChangeIngestor {
+public class FileChangeIngestorTest {
private static final String CONFIG_FILENAME = "config.yml";
private static final String TEST_CONFIG_PATH = "src/test/resources/config.yml";
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestPullHttpChangeIngestorSSL.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/PullHttpChangeIngestorSSLTest.java
similarity index 94%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestPullHttpChangeIngestorSSL.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/PullHttpChangeIngestorSSLTest.java
index 340a131..195cf60 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestPullHttpChangeIngestorSSL.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/PullHttpChangeIngestorSSLTest.java
@@ -18,7 +18,7 @@
package org.apache.nifi.minifi.bootstrap.configuration.ingestors;
import org.apache.nifi.minifi.bootstrap.ConfigurationFileHolder;
-import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.TestPullHttpChangeIngestorCommon;
+import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.PullHttpChangeIngestorCommonTest;
import org.eclipse.jetty.server.ServerConnector;
import org.eclipse.jetty.util.ssl.SslContextFactory;
import org.junit.BeforeClass;
@@ -26,11 +26,11 @@
import java.util.Properties;
-public class TestPullHttpChangeIngestorSSL extends TestPullHttpChangeIngestorCommon {
+public class PullHttpChangeIngestorSSLTest extends PullHttpChangeIngestorCommonTest {
@BeforeClass
public static void setUp() throws Exception {
- TestPullHttpChangeIngestorCommon.init();
+ PullHttpChangeIngestorCommonTest.init();
SslContextFactory ssl = new SslContextFactory();
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestPullHttpChangeIngestor.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/PullHttpChangeIngestorTest.java
similarity index 92%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestPullHttpChangeIngestor.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/PullHttpChangeIngestorTest.java
index f5c6806..f39fbdf 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestPullHttpChangeIngestor.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/PullHttpChangeIngestorTest.java
@@ -18,18 +18,18 @@
package org.apache.nifi.minifi.bootstrap.configuration.ingestors;
import org.apache.nifi.minifi.bootstrap.ConfigurationFileHolder;
-import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.TestPullHttpChangeIngestorCommon;
+import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.PullHttpChangeIngestorCommonTest;
import org.eclipse.jetty.server.ServerConnector;
import org.junit.BeforeClass;
import org.mockito.Mockito;
import java.util.Properties;
-public class TestPullHttpChangeIngestor extends TestPullHttpChangeIngestorCommon {
+public class PullHttpChangeIngestorTest extends PullHttpChangeIngestorCommonTest {
@BeforeClass
public static void setUp() throws Exception {
- TestPullHttpChangeIngestorCommon.init();
+ PullHttpChangeIngestorCommonTest.init();
final ServerConnector http = new ServerConnector(jetty);
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestRestChangeIngestorSSL.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/RestChangeIngestorSSLTest.java
similarity index 97%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestRestChangeIngestorSSL.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/RestChangeIngestorSSLTest.java
index debe772..dada8a5 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestRestChangeIngestorSSL.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/RestChangeIngestorSSLTest.java
@@ -23,7 +23,7 @@
import org.apache.nifi.minifi.bootstrap.configuration.ConfigurationChangeListener;
import org.apache.nifi.minifi.bootstrap.configuration.ConfigurationChangeNotifier;
import org.apache.nifi.minifi.bootstrap.configuration.ListenerHandleResult;
-import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.TestRestChangeIngestorCommon;
+import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.RestChangeIngestorCommonTest;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.mockito.Mockito;
@@ -48,7 +48,7 @@
import static org.mockito.Mockito.when;
-public class TestRestChangeIngestorSSL extends TestRestChangeIngestorCommon {
+public class RestChangeIngestorSSLTest extends RestChangeIngestorCommonTest {
@BeforeClass
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestRestChangeIngestor.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/RestChangeIngestorTest.java
similarity index 94%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestRestChangeIngestor.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/RestChangeIngestorTest.java
index 86a6b4e..5af2d33 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/TestRestChangeIngestor.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/RestChangeIngestorTest.java
@@ -21,7 +21,7 @@
import okhttp3.OkHttpClient;
import org.apache.nifi.minifi.bootstrap.ConfigurationFileHolder;
import org.apache.nifi.minifi.bootstrap.configuration.ConfigurationChangeNotifier;
-import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.TestRestChangeIngestorCommon;
+import org.apache.nifi.minifi.bootstrap.configuration.ingestors.common.RestChangeIngestorCommonTest;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.mockito.Mockito;
@@ -30,7 +30,7 @@
import java.util.Properties;
-public class TestRestChangeIngestor extends TestRestChangeIngestorCommon {
+public class RestChangeIngestorTest extends RestChangeIngestorCommonTest {
@BeforeClass
public static void setUp() throws InterruptedException, MalformedURLException {
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/TestPullHttpChangeIngestorCommon.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/PullHttpChangeIngestorCommonTest.java
similarity index 98%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/TestPullHttpChangeIngestorCommon.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/PullHttpChangeIngestorCommonTest.java
index 53e66d7..229e33d 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/TestPullHttpChangeIngestorCommon.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/PullHttpChangeIngestorCommonTest.java
@@ -47,7 +47,7 @@
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-public abstract class TestPullHttpChangeIngestorCommon {
+public abstract class PullHttpChangeIngestorCommonTest {
public static volatile Server jetty;
public static volatile int port;
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/TestRestChangeIngestorCommon.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/RestChangeIngestorCommonTest.java
similarity index 98%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/TestRestChangeIngestorCommon.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/RestChangeIngestorCommonTest.java
index 72e768a..2f4f7a3 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/TestRestChangeIngestorCommon.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/configuration/ingestors/common/RestChangeIngestorCommonTest.java
@@ -41,7 +41,7 @@
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-public abstract class TestRestChangeIngestorCommon {
+public abstract class RestChangeIngestorCommonTest {
private static String testString = "This is a test string.";
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/status/reporters/TestStatusLogger.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/status/reporters/StatusLoggerTest.java
similarity index 99%
rename from minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/status/reporters/TestStatusLogger.java
rename to minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/status/reporters/StatusLoggerTest.java
index c7fa78f..576dc4e 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/status/reporters/TestStatusLogger.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/status/reporters/StatusLoggerTest.java
@@ -36,7 +36,7 @@
import static org.apache.nifi.minifi.bootstrap.status.reporters.StatusLogger.REPORT_PERIOD_KEY;
import static org.mockito.Mockito.verify;
-public class TestStatusLogger {
+public class StatusLoggerTest {
private static final String MOCK_STATUS = "FlowStatusReport{controllerServiceStatusList=null, processorStatusList=[{name='TailFile', processorHealth={runStatus='Running', hasBulletins=false, " +
"validationErrorList=[]}, processorStats=null, bulletinList=null}], connectionStatusList=null, remoteProcessingGroupStatusList=null, instanceStatus=null, systemDiagnosticsStatus=null," +
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/util/ConfigTransformerTest.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/util/ConfigTransformerTest.java
index ecd9001..67c5916 100644
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/util/ConfigTransformerTest.java
+++ b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/util/ConfigTransformerTest.java
@@ -17,7 +17,38 @@
package org.apache.nifi.minifi.bootstrap.util;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.xpath.XPath;
+import javax.xml.xpath.XPathConstants;
+import javax.xml.xpath.XPathExpressionException;
+import javax.xml.xpath.XPathFactory;
+
import org.apache.nifi.minifi.bootstrap.configuration.ConfigurationChangeException;
+import org.apache.nifi.minifi.bootstrap.exception.InvalidConfigurationException;
import org.apache.nifi.minifi.commons.schema.ConfigSchema;
import org.apache.nifi.minifi.commons.schema.ConnectionSchema;
import org.apache.nifi.minifi.commons.schema.ControllerServiceSchema;
@@ -36,33 +67,6 @@
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
-import javax.xml.parsers.DocumentBuilder;
-import javax.xml.parsers.DocumentBuilderFactory;
-import javax.xml.parsers.ParserConfigurationException;
-import javax.xml.xpath.XPath;
-import javax.xml.xpath.XPathConstants;
-import javax.xml.xpath.XPathExpressionException;
-import javax.xml.xpath.XPathFactory;
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.Comparator;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
public class ConfigTransformerTest {
public static final Map<String, Integer> PG_ELEMENT_ORDER_MAP = generateOrderMap(
Arrays.asList("processor", "inputPort", "outputPort", "funnel", "processGroup", "remoteProcessGroup", "connection"));
@@ -189,6 +193,195 @@
}
}
+ @Test
+ public void doesTransformFile() throws Exception {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config.yml", "./target/");
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void doesTransformV1File() throws Exception {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-v1.yml", "./target/");
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void doesTransformInputStream() throws Exception {
+ File inputFile = new File("./src/test/resources/config.yml");
+ ConfigTransformer.transformConfigFile(new FileInputStream(inputFile), "./target/");
+
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void doesTransformOnDefaultFile() throws Exception {
+ ConfigTransformer.transformConfigFile("./src/test/resources/default.yml", "./target/");
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void doesTransformOnMultipleProcessors() throws Exception {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-processors.yml", "./target/");
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void doesTransformOnMultipleRemoteProcessGroups() throws Exception {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-RPGs.yml", "./target/");
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void doesTransformOnMultipleInputPorts() throws Exception {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-input-ports.yml", "./target/");
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void doesTransformOnMinimal() throws Exception {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-minimal.yml", "./target/");
+ File nifiPropertiesFile = new File("./target/nifi.properties");
+
+ assertTrue(nifiPropertiesFile.exists());
+ assertTrue(nifiPropertiesFile.canRead());
+
+ nifiPropertiesFile.deleteOnExit();
+
+ File flowXml = new File("./target/flow.xml.gz");
+ assertTrue(flowXml.exists());
+ assertTrue(flowXml.canRead());
+
+ flowXml.deleteOnExit();
+ }
+
+ @Test
+ public void handleTransformInvalidFile() throws Exception {
+ try {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-invalid.yml", "./target/");
+ fail("Invalid configuration file was not detected.");
+ } catch (SchemaLoaderException e){
+ assertEquals("Provided YAML configuration is not a Map", e.getMessage());
+ }
+ }
+
+ @Test
+ public void handleTransformMalformedField() throws Exception {
+ try {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-malformed-field.yml", "./target/");
+ fail("Invalid configuration file was not detected.");
+ } catch (InvalidConfigurationException e){
+ assertEquals("Failed to transform config file due to:['threshold' in section 'Swap' because it is found but could not be parsed as a Number]", e.getMessage());
+ }
+ }
+
+ @Test
+ public void handleTransformEmptyFile() throws Exception {
+ try {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-empty.yml", "./target/");
+ fail("Invalid configuration file was not detected.");
+ } catch (SchemaLoaderException e){
+ assertEquals("Provided YAML configuration is not a Map", e.getMessage());
+ }
+ }
+
+ @Test
+ public void handleTransformFileMissingRequiredField() throws Exception {
+ try {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-missing-required-field.yml", "./target/");
+ fail("Invalid configuration file was not detected.");
+ } catch (InvalidConfigurationException e){
+ assertEquals("Failed to transform config file due to:['class' in section 'Processors' because it was not found and it is required]", e.getMessage());
+ }
+ }
+
+ @Test
+ public void handleTransformFileMultipleProblems() throws Exception {
+ try {
+ ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-problems.yml", "./target/");
+ fail("Invalid configuration file was not detected.");
+ } catch (InvalidConfigurationException e){
+ assertEquals("Failed to transform config file due to:['class' in section 'Processors' because it was not found and it is required], " +
+ "['scheduling strategy' in section 'Provenance Reporting' because it is not a valid scheduling strategy], " +
+ "['source name' in section 'Connections' because it was not found and it is required]", e.getMessage());
+ }
+ }
+
public void testConfigFileTransform(String configFile) throws Exception {
ConfigSchema configSchema = SchemaLoader.loadConfigSchemaFromYaml(ConfigTransformerTest.class.getClassLoader().getResourceAsStream(configFile));
@@ -354,7 +547,7 @@
Element item = (Element) propertyElements.item(i);
properties.put(getText(item, "name"), getText(item, "value"));
}
- assertEquals(expected.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> nullToEmpty(e.getValue()))), properties);
+ assertEquals(expected.entrySet().stream().collect(Collectors.toMap(Map.Entry<String, Object>::getKey, e -> nullToEmpty(e.getValue()))), properties);
}
private String getText(Element element, String path) throws XPathExpressionException {
diff --git a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/util/TestConfigTransformer.java b/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/util/TestConfigTransformer.java
deleted file mode 100644
index d644ed3..0000000
--- a/minifi-bootstrap/src/test/java/org/apache/nifi/minifi/bootstrap/util/TestConfigTransformer.java
+++ /dev/null
@@ -1,221 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.nifi.minifi.bootstrap.util;
-
-import org.apache.nifi.minifi.bootstrap.exception.InvalidConfigurationException;
-import org.apache.nifi.minifi.commons.schema.exception.SchemaLoaderException;
-import org.junit.Test;
-
-import java.io.File;
-import java.io.FileInputStream;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
-public class TestConfigTransformer {
-
- @Test
- public void doesTransformFile() throws Exception {
- ConfigTransformer.transformConfigFile("./src/test/resources/config.yml", "./target/");
- File nifiPropertiesFile = new File("./target/nifi.properties");
-
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void doesTransformV1File() throws Exception {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-v1.yml", "./target/");
- File nifiPropertiesFile = new File("./target/nifi.properties");
-
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void doesTransformInputStream() throws Exception {
- File inputFile = new File("./src/test/resources/config.yml");
- ConfigTransformer.transformConfigFile(new FileInputStream(inputFile), "./target/");
-
- File nifiPropertiesFile = new File("./target/nifi.properties");
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void doesTransformOnDefaultFile() throws Exception {
- ConfigTransformer.transformConfigFile("./src/test/resources/default.yml", "./target/");
- File nifiPropertiesFile = new File("./target/nifi.properties");
-
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void doesTransformOnMultipleProcessors() throws Exception {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-processors.yml", "./target/");
- File nifiPropertiesFile = new File("./target/nifi.properties");
-
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void doesTransformOnMultipleRemoteProcessGroups() throws Exception {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-RPGs.yml", "./target/");
- File nifiPropertiesFile = new File("./target/nifi.properties");
-
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void doesTransformOnMultipleInputPorts() throws Exception {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-input-ports.yml", "./target/");
- File nifiPropertiesFile = new File("./target/nifi.properties");
-
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void doesTransformOnMinimal() throws Exception {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-minimal.yml", "./target/");
- File nifiPropertiesFile = new File("./target/nifi.properties");
-
- assertTrue(nifiPropertiesFile.exists());
- assertTrue(nifiPropertiesFile.canRead());
-
- nifiPropertiesFile.deleteOnExit();
-
- File flowXml = new File("./target/flow.xml.gz");
- assertTrue(flowXml.exists());
- assertTrue(flowXml.canRead());
-
- flowXml.deleteOnExit();
- }
-
- @Test
- public void handleTransformInvalidFile() throws Exception {
- try {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-invalid.yml", "./target/");
- fail("Invalid configuration file was not detected.");
- } catch (SchemaLoaderException e){
- assertEquals("Provided YAML configuration is not a Map", e.getMessage());
- }
- }
-
- @Test
- public void handleTransformMalformedField() throws Exception {
- try {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-malformed-field.yml", "./target/");
- fail("Invalid configuration file was not detected.");
- } catch (InvalidConfigurationException e){
- assertEquals("Failed to transform config file due to:['threshold' in section 'Swap' because it is found but could not be parsed as a Number]", e.getMessage());
- }
- }
-
- @Test
- public void handleTransformEmptyFile() throws Exception {
- try {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-empty.yml", "./target/");
- fail("Invalid configuration file was not detected.");
- } catch (SchemaLoaderException e){
- assertEquals("Provided YAML configuration is not a Map", e.getMessage());
- }
- }
-
- @Test
- public void handleTransformFileMissingRequiredField() throws Exception {
- try {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-missing-required-field.yml", "./target/");
- fail("Invalid configuration file was not detected.");
- } catch (InvalidConfigurationException e){
- assertEquals("Failed to transform config file due to:['class' in section 'Processors' because it was not found and it is required]", e.getMessage());
- }
- }
-
- @Test
- public void handleTransformFileMultipleProblems() throws Exception {
- try {
- ConfigTransformer.transformConfigFile("./src/test/resources/config-multiple-problems.yml", "./target/");
- fail("Invalid configuration file was not detected.");
- } catch (InvalidConfigurationException e){
- assertEquals("Failed to transform config file due to:['class' in section 'Processors' because it was not found and it is required], " +
- "['scheduling strategy' in section 'Provenance Reporting' because it is not a valid scheduling strategy], " +
- "['source name' in section 'Connections' because it was not found and it is required]", e.getMessage());
- }
- }
-}
diff --git a/minifi-commons/minifi-utils/src/test/java/org/apache/nifi/minifi/commons/status/TestStatusReport.java b/minifi-commons/minifi-utils/src/test/java/org/apache/nifi/minifi/commons/status/StatusReportTest.java
similarity index 98%
rename from minifi-commons/minifi-utils/src/test/java/org/apache/nifi/minifi/commons/status/TestStatusReport.java
rename to minifi-commons/minifi-utils/src/test/java/org/apache/nifi/minifi/commons/status/StatusReportTest.java
index fc697e3..8fc442f 100644
--- a/minifi-commons/minifi-utils/src/test/java/org/apache/nifi/minifi/commons/status/TestStatusReport.java
+++ b/minifi-commons/minifi-utils/src/test/java/org/apache/nifi/minifi/commons/status/StatusReportTest.java
@@ -35,7 +35,7 @@
import static org.apache.nifi.minifi.commons.status.util.StatusReportPopulator.addSystemDiagnosticStatus;
import static org.junit.Assert.assertEquals;
-public class TestStatusReport {
+public class StatusReportTest {
@Test
public void verifySerializableFullyPopulated() throws IOException, ClassNotFoundException {
diff --git a/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/status/TestStatusConfigReporter.java b/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/status/StatusConfigReporterTest.java
similarity index 92%
rename from minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/status/TestStatusConfigReporter.java
rename to minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/status/StatusConfigReporterTest.java
index ee2f115..171400a 100644
--- a/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/status/TestStatusConfigReporter.java
+++ b/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/status/StatusConfigReporterTest.java
@@ -69,7 +69,7 @@
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-public class TestStatusConfigReporter {
+public class StatusConfigReporterTest {
private FlowController mockFlowController;
private ProcessGroupStatus rootGroupStatus;
private BulletinRepository bulletinRepo;
@@ -94,7 +94,7 @@
populateProcessor(false, false);
String statusRequest = "processor:all:health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -109,7 +109,7 @@
populateProcessor(true, false);
String statusRequest = "processor:all:health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -124,7 +124,7 @@
populateProcessor(true, true);
String statusRequest = "processor:all:health, stats, bulletins";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -139,7 +139,7 @@
populateConnection();
String statusRequest = "connection:all:health";
- FlowStatusReport status = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport status = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -155,7 +155,7 @@
populateConnection();
String statusRequest = "connection:all:health, stats";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -172,7 +172,7 @@
populateProcessor(false, false);
String statusRequest = "connection:connectionId:health; processor:UpdateAttributeProcessorId:health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
addConnectionStatus(expected, true, false);
@@ -189,7 +189,7 @@
populateReportingTask(false, false);
String statusRequest = "provenanceReporting:health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -204,7 +204,7 @@
populateReportingTask(true, false);
String statusRequest = "provenanceReporting:bulletins";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -219,7 +219,7 @@
populateReportingTask(true, true);
String statusRequest = "provenanceReporting:health,bulletins";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -234,7 +234,7 @@
populateSystemDiagnostics();
String statusRequest = "systemDiagnostics:heap";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -249,7 +249,7 @@
populateSystemDiagnostics();
String statusRequest = "systemDiagnostics:processorStats";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -264,7 +264,7 @@
populateSystemDiagnostics();
String statusRequest = "systemDiagnostics:flowfilerepositoryusage";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -279,7 +279,7 @@
populateSystemDiagnostics();
String statusRequest = "systemDiagnostics:contentrepositoryusage";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -294,7 +294,7 @@
populateSystemDiagnostics();
String statusRequest = "systemDiagnostics:garbagecollection";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -310,7 +310,7 @@
populateSystemDiagnostics();
String statusRequest = "systemDiagnostics:garbagecollection, heap, processorstats, contentrepositoryusage, flowfilerepositoryusage";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -325,7 +325,7 @@
populateInstance(false);
String statusRequest = "instance:health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -339,7 +339,7 @@
populateInstance(true);
String statusRequest = "instance:bulletins";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -354,7 +354,7 @@
populateInstance(false);
String statusRequest = "instance:stats";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -369,7 +369,7 @@
populateInstance(true);
String statusRequest = "instance:stats, bulletins, health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -384,7 +384,7 @@
populateControllerService(false, false);
String statusRequest = "controllerServices:health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -399,7 +399,7 @@
populateControllerService(false, true);
String statusRequest = "controllerServices:bulletins";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -415,7 +415,7 @@
String statusRequest = "controllerServices:bulletins, health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -430,7 +430,7 @@
populateRemoteProcessGroup(false, false);
String statusRequest = "remoteProcessGroup:all:health";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -445,7 +445,7 @@
populateRemoteProcessGroup(true, false);
String statusRequest = "remoteProcessGroup:all:bulletins";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -460,7 +460,7 @@
populateRemoteProcessGroup(false, false);
String statusRequest = "remoteProcessGroup:all:inputPorts";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -475,7 +475,7 @@
populateRemoteProcessGroup(false, false);
String statusRequest = "remoteProcessGroup:all:outputPorts";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -490,7 +490,7 @@
populateRemoteProcessGroup(false, false);
String statusRequest = "remoteProcessGroup:all:stats";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -506,7 +506,7 @@
populateRemoteProcessGroup(true, true);
String statusRequest = "remoteProcessGroup:all:health, bulletins, inputPorts, outputPorts, stats";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
@@ -532,7 +532,7 @@
"processorstats, contentrepositoryusage, flowfilerepositoryusage; connection:all:health,stats; provenanceReporting:health,bulletins; remoteProcessGroup:all:health, " +
"bulletins, inputPorts, outputPorts, stats";
- FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(TestStatusConfigReporter.class));
+ FlowStatusReport actual = StatusConfigReporter.getStatus(mockFlowController, statusRequest, LoggerFactory.getLogger(StatusConfigReporterTest.class));
FlowStatusReport expected = new FlowStatusReport();
expected.setErrorsGeneratingReport(Collections.EMPTY_LIST);
diff --git a/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestMiNiFiPersistentProvenanceRepository.java b/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java
similarity index 99%
rename from minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestMiNiFiPersistentProvenanceRepository.java
rename to minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java
index 0dd5f65..08d5fc6 100644
--- a/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestMiNiFiPersistentProvenanceRepository.java
+++ b/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java
@@ -56,7 +56,7 @@
import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.mock;
-public class TestMiNiFiPersistentProvenanceRepository {
+public class MiNiFiPersistentProvenanceRepositoryTest {
@Rule
public TestName name = new TestName();
