@Setter
public class Appconfig {
private CallsObj[] service_calls;
- private TreeMap<String, DmaapObj> stream_publishes;
- private TreeMap<String, DmaapObj> stream_subcribes;
+ private TreeMap<String, DmaapObj> streams_publishes;
+ private TreeMap<String, DmaapObj> streams_subscribes;
private TreeMap<String, Object> params;
@JsonAnyGetter
}
}
- this.setStream_publishes(streamPublishes);
- this.setStream_subcribes(streamSubscribes);
+ this.setStreams_publishes(streamPublishes);
+ this.setStreams_subscribes(streamSubscribes);
//set the parameters into the appconfig
TreeMap<String, Object> parameters = new TreeMap<String, Object>();
ArrayList<DmaapStreams> streams_subscribes;
private TreeMap<String, Object> tls_info;
private ResourceConfig resource_config;
- private boolean useExisting;
+ //private boolean useExisting;
public TreeMap<String, LinkedHashMap<String, Object>> createOnapProperties(TreeMap<String, LinkedHashMap<String, Object>> inps, ComponentSpec cs, String override) {
TreeMap<String, LinkedHashMap<String, Object>> retInputs = new TreeMap<String, LinkedHashMap<String, Object>>();
for(int i = 0; i < p.length(); i++) {
if(p.charAt(i) == ':') {
internal = '"' + internal + '"';
- internal = "concat:['" + internal + "', {get_input: external_port}]";
+ internal = "concat: ['" + internal + "', {get_input: external_port}]";
ports.add(internal);
}
if(p.charAt(i) == ':' && !foundPort) {
//set the imports
Imports imps = new Imports();
if(importPath.equals("")) {
- imps.createDmaapImports();
+ bp.setImports(imps.createDmaapImports());
}
else {
- imps.createImportsFromFile(importPath);
+ bp.setImports(imps.createImportsFromFile(importPath));
}
- bp.setImports(imps.getImports());
+ //bp.setImports(imps.getImports());
//set and create the node templates
TreeMap<String, Node> nodeTemplate = new TreeMap();
GetInput topicInput = new GetInput();
topicInput.setGet_input(name + "_name");
props.setFeed_name(topicInput);
- props.setUseExisting(true);
+ //props.setUseExisting(true);
retInputs.put(name + "_name", stringType);
this.setProperties(props);
GetInput topicInput = new GetInput();
topicInput.setGet_input(name + "_name");
props.setTopic_name(topicInput);
- props.setUseExisting(true);
+ //props.setUseExisting(true);
retInputs.put(name + "_name", stringType);
this.setProperties(props);
OnapNode node = (OnapNode) bp.getNode_templates().get("test.component.spec");
boolean test = false;
- if(!node.getProperties().getApplication_config().getStream_publishes().isEmpty()) {
+ if(!node.getProperties().getApplication_config().getStreams_publishes().isEmpty()) {
test = true;
System.out.println("tst");
}