* 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.*;
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" );
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");
+ t.setFqtn(t.genFqtn());
return t;
}