Change-Id: I4cbdb4f9ad5af26502619cb9358086bbf667bc0f
Issue-ID: SO-719
Signed-off-by: Lukasz Muszkieta <lukasz.muszkieta@nokia.com>
httpClient = HttpClientBuilder.create().build();
pnfCorrelationIdToThreadMap = new ConcurrentHashMap<>();
dmaapHost = PropertyConfiguration.getInstance().getProperties(PropertyConfiguration.MSO_BPMN_URN_PROPERTIES)
- .get("dmaapHost");
+ .get("mso.dmaap.host");
dmaapPort = Integer.parseInt(PropertyConfiguration.getInstance()
- .getProperties(PropertyConfiguration.MSO_BPMN_URN_PROPERTIES).get("dmaapPort"));
+ .getProperties(PropertyConfiguration.MSO_BPMN_URN_PROPERTIES).get("mso.dmaap.port"));
executor = null;
getRequest = new HttpGet(buildURI());
}
private Map<String, String> createProperties() {
Map<String, String> map = new HashMap<>();
- map.put("dmaapHost", HOST);
- map.put("dmaapPort", String.valueOf(PORT));
+ map.put("mso.dmaap.host", HOST);
+ map.put("mso.dmaap.port", String.valueOf(PORT));
return map;
}