X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdbcapi.git;a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Ftestframework%2FDmaapObjectFactory.java;h=0bce10654056b7c9fcb1d48e3fabf9e482069501;hp=9d3c8688e915097208a91b866c9f2644c5f52195;hb=ac03a4b32eae987019cec2cd39d6d252fb320c2f;hpb=fb8a36eeec10b389a3ccc79c5f31ee925243c1b8 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..0bce106 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 ) {