diff options
Diffstat (limited to 'src/test/java')
| -rw-r--r-- | src/test/java/org/onap/dmaap/mr/cambria/embed/KafkaLocal.java | 2 | ||||
| -rw-r--r-- | src/test/java/org/onap/dmaap/service/UIRestServicesTest.java | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/test/java/org/onap/dmaap/mr/cambria/embed/KafkaLocal.java b/src/test/java/org/onap/dmaap/mr/cambria/embed/KafkaLocal.java index 17c5bbb..43dcd6c 100644 --- a/src/test/java/org/onap/dmaap/mr/cambria/embed/KafkaLocal.java +++ b/src/test/java/org/onap/dmaap/mr/cambria/embed/KafkaLocal.java @@ -41,7 +41,7 @@ public class KafkaLocal { zookeeper = new ZooKeeperLocal(zkProperties); zookeeper.run(); System.out.println("done"); - + Thread.sleep(5000); //start local kafka broker final scala.Option<String> prefix = scala.Option.apply("kafka"); kafka = new KafkaServer(kafkaConfig, Time.SYSTEM, prefix, false); diff --git a/src/test/java/org/onap/dmaap/service/UIRestServicesTest.java b/src/test/java/org/onap/dmaap/service/UIRestServicesTest.java index 3024484..77d8b01 100644 --- a/src/test/java/org/onap/dmaap/service/UIRestServicesTest.java +++ b/src/test/java/org/onap/dmaap/service/UIRestServicesTest.java @@ -107,7 +107,7 @@ public class UIRestServicesTest { Class clazz = null; Method method = null; try { - clazz = Class.forName("UIRestServices"); + clazz = Class.forName("org.onap.dmaap.service.UIRestServices"); Object obj = clazz.newInstance(); method = clazz.getDeclaredMethod("getDmaapContext", null); method.setAccessible(true); |