X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Ftestframework%2FDmaapObjectFactory.java;h=901b4ea3ee47e89c8a18b27c7a17075f9ee5037f;hb=bfe1f5204aa40a4178c005f23e530401b991ac58;hp=9d3c8688e915097208a91b866c9f2644c5f52195;hpb=d5d37c0477744cbaa6a9d9fc690c0dafbb2d1868;p=dmaap%2Fdbcapi.git diff --git a/src/test/java/org/onap/dmaap/dbcapi/testframework/DmaapObjectFactory.java b/src/test/java/org/onap/dmaap/dbcapi/testframework/DmaapObjectFactory.java index 9d3c868..901b4ea 100644 --- a/src/test/java/org/onap/dmaap/dbcapi/testframework/DmaapObjectFactory.java +++ b/src/test/java/org/onap/dmaap/dbcapi/testframework/DmaapObjectFactory.java @@ -71,6 +71,8 @@ public class DmaapObjectFactory { private static final String edge_subnet = "10.10.20.0/24"; private static final String edge_cluster_fqdn = "localhost"; private static final String[]hosts = { "host1", "host2", "host3" }; + private static final String port = "3904"; + private static final String prot = "http"; public Dmaap genDmaap() { return new Dmaap( dmaap_ver, dmaap_topic_root, dmaap_name, dmaap_dr, dmaap_log_url, dmaap_mm_topic, "nk", "ako" ); @@ -86,9 +88,9 @@ public class DmaapObjectFactory { public MR_Cluster genMR_Cluster( String layer ) { if ( layer.contains( "edge" ) ) { - return new MR_Cluster( edge_loc, edge_cluster_fqdn, "ignore", hosts ); + return new MR_Cluster( edge_loc, edge_cluster_fqdn, prot, port ); } - return new MR_Cluster( central_loc, central_cluster_fqdn, "ignore", hosts ); + return new MR_Cluster( central_loc, central_cluster_fqdn, prot, port ); } public Topic genSimpleTopic( String tname ) { @@ -97,6 +99,7 @@ public class DmaapObjectFactory { t.setFqtnStyle( FqtnType.Validator("none") ); t.setTopicDescription( "a simple Topic named " + tname ); t.setOwner( "ut"); + t.setFqtn(t.genFqtn()); return t; }