Flatten and Aggregate features in JSON array processing

[dcaegen2/services.git] / components / datalake-handler / feeder / src / test / java / org / onap / datalake / feeder / config / ApplicationConfigurationTest.java

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 934451f..0c56d5a 100644 (file)
--- 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,23 +46,34 @@ 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.getCouchbaseHost());
-               assertNotNull(config.getCouchbaseUser());
-               assertNotNull(config.getCouchbasePass());
-               assertNotNull(config.getCouchbaseBucket());
+        assertNotNull(config.getDmaapZookeeperHostPort());
+        assertNotNull(config.getDmaapKafkaHostPort());
+        assertNotNull(config.getDmaapKafkaGroup());
+        assertTrue(config.getDmaapKafkaTimeout() > 0L);
+        assertTrue(config.getDmaapCheckNewTopicInterval() > 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.getDmaapKafkaExclude());
+        
+        assertNotNull(config.isAsync());
+        assertNotNull(config.isEnableSSL());
+        assertNotNull(config.getDefaultTopicName());
+        assertNotNull(config.getRawDataLabel());
+        assertNotNull(config.getTimestampLabel());
+        assertNotNull(config.getElasticsearchType());
+        assertNotNull(config.getDatalakeVersion());
+        
+      //HDFS
+        assertTrue(config.getHdfsBatchSize()>0);
+        assertTrue(config.getHdfsBufferSize()>0);
+        assertTrue(config.getHdfsFlushInterval()>0);
+    }
 
 }