</parent>
<groupId>org.onap.dcaegen2.services.components</groupId>
<artifactId>slice-analysis-ms</artifactId>
- <version>1.1.4-SNAPSHOT</version>
+ <version>1.1.3-SNAPSHOT</version>
<name>dcaegen2-services-slice-analysis-ms</name>
<description>Network slice PM analyser</description>
<packaging>jar</packaging>
@PostConstruct
public void init(){
configuration = Configuration.getInstance();
- ccvpnPmDatastore = new CCVPNPmDatastore();
vesNotifChangeIdentifier = configuration.getVesNotifChangeIdentifier();
vesNotfiChangeType = configuration.getVesNotifChangeType();
}
}
/**
- * Parse Performance dmaap notification and save to DB
+ * Parse Performance dmaap notification and save to DB
* @param msg incoming message
*/
private void handleNotification(String msg) {
notifChangeIdentifier = output.getChangeIdentifier();
notifChangeType = output.getChangeType();
if (notifChangeType.equals(vesNotfiChangeType)
- && notifChangeIdentifier.equals(vesNotifChangeIdentifier)) {
+ && notifChangeIdentifier.equals(vesNotifChangeIdentifier)) {
cllId = output.getArrayOfNamedHashMap().get(0).getHashMap().getCllId();
uniId = output.getArrayOfNamedHashMap().get(0).getHashMap().getUniId();
bw = output.getArrayOfNamedHashMap().get(0).getHashMap().getBandwidthValue();
}
-}
\ No newline at end of file
+}
package org.onap.slice.analysis.ms.dmaap;
import com.fasterxml.jackson.databind.ObjectMapper;
-import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.InjectMocks;
import org.mockito.Mockito;
import org.mockito.Spy;
-import org.onap.slice.analysis.ms.models.Configuration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
-import com.google.gson.Gson;
-import com.google.gson.JsonObject;
+
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
@InjectMocks
VesNotificationCallback vesNotificationCallback;
- @Before
- public void init() throws IOException {
- Configuration configuration = Configuration.getInstance();
- String configAllJson = new String(Files.readAllBytes(Paths.get("src/test/resources/config_all.json")));
- JsonObject configAll = new Gson().fromJson(configAllJson, JsonObject.class);
- JsonObject config = configAll.getAsJsonObject("config");
- configuration.updateConfigurationFromJsonObject(config);
- vesNotificationCallback.init();
- }
-
@Test
public void initTest() {
+ vesNotificationCallback.init();
Mockito.verify(vesNotificationCallback, Mockito.atLeastOnce()).init();
}
@Test
- public void activateCallBackTest() throws Exception{
- String input = new String(Files.readAllBytes(Paths.get("src/test/resources/vesCCVPNNotiModel.json")));
+ public void activateCallBackTest() {
+ String input = null;
+ try {
+ input = new String(Files.readAllBytes(Paths.get("src/test/resources/vesCCVPNNotiModel.json")));
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
vesNotificationCallback.activateCallBack(input);
Mockito.verify(vesNotificationCallback, Mockito.atLeastOnce()).activateCallBack(Mockito.anyString());
}
-
}