Merge "Unit test code for datalake seed code"

1 files changed, 31 insertions, 35 deletions

diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/config/ApplicationConfigurationTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/config/ApplicationConfigurationTest.java
index 02db5a25..3f1f37c1 100644
--- a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/config/ApplicationConfigurationTest.java
+++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/config/ApplicationConfigurationTest.java
@@ -1,33 +1,29 @@
 /*
-* ============LICENSE_START=======================================================
-* ONAP : DATALAKE
-* ================================================================================
-* Copyright 2019 China Mobile
-*=================================================================================
-* Licensed 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.
-* ============LICENSE_END=========================================================
-*/
+ * ============LICENSE_START=======================================================
+ * ONAP : DATALAKE
+ * ================================================================================
+ * Copyright 2019 China Mobile
+ *=================================================================================
+ * Licensed 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.
+ * ============LICENSE_END=========================================================
+ */
 
 package org.onap.datalake.feeder.config;
 
 import org.junit.Test;
 import org.junit.runner.RunWith;
-import org.onap.datalake.feeder.Application;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.ConfigFileApplicationContextInitializer;
 import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import static org.junit.Assert.assertNotNull;
@@ -35,9 +31,8 @@ import static org.junit.Assert.assertTrue;
 
 /**
  * test ApplicationConfiguration
- * 
- * @author Guobiao Mo
  *
+ * @author Guobiao Mo
  */
 //@RunWith(SpringRunner.class)
 //@SpringBootTest
@@ -51,19 +46,20 @@ import static org.junit.Assert.assertTrue;
 //@ActiveProfiles("test")
 public class ApplicationConfigurationTest {
 
-	@Autowired
-	private ApplicationConfiguration config;
+    @Autowired
+    private ApplicationConfiguration config;
 
-	@Test
-	public void readConfig() {
+    @Test
+    public void readConfig() {
 
-		assertNotNull(config.getDmaapZookeeperHostPort());
-		assertNotNull(config.getDmaapKafkaHostPort());
-		assertNotNull(config.getDmaapKafkaGroup());
-		assertTrue(config.getDmaapKafkaTimeout() > 0L);
-		assertTrue(config.getDmaapCheckNewTopicIntervalInSec() > 0);
+        assertNotNull(config.getDmaapZookeeperHostPort());
+        assertNotNull(config.getDmaapKafkaHostPort());
+        assertNotNull(config.getDmaapKafkaGroup());
+        assertTrue(config.getDmaapKafkaTimeout() > 0L);
+        assertTrue(config.getDmaapCheckNewTopicIntervalInSec() > 0);
 
-		assertTrue(config.getKafkaConsumerCount() > 0);
-	}
+        assertTrue(config.getKafkaConsumerCount() > 0);
+        assertNotNull(config.isAsync());
+    }
 
 }