fix waitforyellow in dbclient

[ccsdk/features.git] / sdnr / wt / data-provider / setup / src / test / java / org / onap / ccsdk / features / sdnr / wt / dataprovider / setup / TestMigrationProvider.java

diff --git a/sdnr/wt/data-provider/setup/src/test/java/org/onap/ccsdk/features/sdnr/wt/dataprovider/setup/TestMigrationProvider.java b/sdnr/wt/data-provider/setup/src/test/java/org/onap/ccsdk/features/sdnr/wt/dataprovider/setup/TestMigrationProvider.java
index 483ca0b..1ec1911 100644 (file)
--- a/sdnr/wt/data-provider/setup/src/test/java/org/onap/ccsdk/features/sdnr/wt/dataprovider/setup/TestMigrationProvider.java
+++ b/sdnr/wt/data-provider/setup/src/test/java/org/onap/ccsdk/features/sdnr/wt/dataprovider/setup/TestMigrationProvider.java
@@ -37,23 +37,23 @@ import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.Release;
  */
 public class TestMigrationProvider {
 
-         private static final String FRANKFURT_BACKUP_FILE = "src/test/resources/test2.bak.json";
-       public static HostInfo[] hosts = new HostInfo[] { new HostInfo("localhost", Integer
-                   .valueOf(System.getProperty("databaseport") != null ? System.getProperty("databaseport") : "49200")) };
+      private static final String FRANKFURT_BACKUP_FILE = "src/test/resources/test2.bak.json";
+    public static HostInfo[] hosts = new HostInfo[] { new HostInfo("localhost", Integer
+                .valueOf(System.getProperty("databaseport") != null ? System.getProperty("databaseport") : "49200")) };
 
-       @Test
-       public void testCreateImport() {
-               DataMigrationProviderImpl provider = new DataMigrationProviderImpl(hosts, null, null,true);
-               
-               try {
-                       //create el alto db infrastructure
-                       provider.initDatabase(Release.FRANKFURT_R1, 5, 1, "", true,10000);
-                       //import data into database
-                       DataMigrationReport report = provider.importData(FRANKFURT_BACKUP_FILE, false, Release.FRANKFURT_R1);
-                       assertTrue(report.completed());
-                       assertEquals(Release.FRANKFURT_R1, provider.autoDetectRelease());
-               } catch (Exception e) {
-                       fail(e.getMessage());
-               }
-       }
+    @Test
+    public void testCreateImport() {
+        DataMigrationProviderImpl provider = new DataMigrationProviderImpl(hosts, null, null,true,5000);
+
+        try {
+            //create el alto db infrastructure
+            provider.initDatabase(Release.FRANKFURT_R1, 5, 1, "", true,10000);
+            //import data into database
+            DataMigrationReport report = provider.importData(FRANKFURT_BACKUP_FILE, false, Release.FRANKFURT_R1);
+            assertTrue(report.completed());
+            assertEquals(Release.FRANKFURT_R1, provider.autoDetectRelease());
+        } catch (Exception e) {
+            fail(e.getMessage());
+        }
+    }
 }