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=44b3e41dbeede867b8925ee3c99f5bd83c811094;hb=ac03a4b32eae987019cec2cd39d6d252fb320c2f;hpb=41317d52ae9991ff49ca21c72aceb6037dffc9ad 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 44b3e41..0bce106 100644 --- a/src/test/java/org/onap/dmaap/dbcapi/testframework/DmaapObjectFactory.java +++ b/src/test/java/org/onap/dmaap/dbcapi/testframework/DmaapObjectFactory.java @@ -17,8 +17,16 @@ * limitations under the License. * ============LICENSE_END========================================================= */ -package org.onap.dmaap.dbcapi.model; - +package org.onap.dmaap.dbcapi.testframework; + +import org.onap.dmaap.dbcapi.model.DR_Node; +import org.onap.dmaap.dbcapi.model.DR_Sub; +import org.onap.dmaap.dbcapi.model.DcaeLocation; +import org.onap.dmaap.dbcapi.model.Dmaap; +import org.onap.dmaap.dbcapi.model.FqtnType; +import org.onap.dmaap.dbcapi.model.MR_Client; +import org.onap.dmaap.dbcapi.model.MR_Cluster; +import org.onap.dmaap.dbcapi.model.Topic; import org.onap.dmaap.dbcapi.util.RandomInteger; import static org.junit.Assert.*; @@ -63,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" ); @@ -78,16 +88,17 @@ 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 ) { Topic t = new Topic(); t.setTopicName( tname ); t.setFqtnStyle( FqtnType.Validator("none") ); - t.getFqtn(); + t.setTopicDescription( "a simple Topic named " + tname ); + t.setOwner( "ut"); return t; }