summaryrefslogtreecommitdiffstats
path: root/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java
diff options
context:
space:
mode:
authorDenes Nemeth <denes.nemeth@nokia.com>2018-04-10 22:48:30 +0200
committerDenes Nemeth <denes.nemeth@nokia.com>2018-04-11 00:05:42 +0200
commit20297ddd0487602208bd98d89b8acbf940952e7b (patch)
tree5f0b9e8af04e2b3685f6da47a4bcac7a9b14377e /nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java
parenta995e82e01a3315940051ca55133c9cb14eccc6b (diff)
Fix automatic package conversion
Issue-ID: VFC-728 Signed-off-by: Denes Nemeth <denes.nemeth@nokia.com> Change-Id: Ie015f2e5406329f16e74ab8abd44060dfc44148a
Diffstat (limited to 'nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java')
-rw-r--r--nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java15
1 files changed, 5 insertions, 10 deletions
diff --git a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java
index ceb0335d..23c2e4bf 100644
--- a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java
+++ b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/NokiaSvnfmApplication.java
@@ -18,14 +18,10 @@ package org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.onap.core.SelfRegistrationManager;
-import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.util.SystemFunctions;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.vnfm.JobManager;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener;
@@ -71,7 +67,7 @@ public class NokiaSvnfmApplication {
private ExecutorService executorService = newCachedThreadPool();
@Autowired
- SelfRegistrationTrigger(SelfRegistrationManager selfRegistrationManager, JobManager jobManager){
+ SelfRegistrationTrigger(SelfRegistrationManager selfRegistrationManager, JobManager jobManager) {
this.jobManager = jobManager;
this.selfRegistrationManager = selfRegistrationManager;
}
@@ -90,13 +86,12 @@ public class NokiaSvnfmApplication {
return true;
};
executorService.submit(() -> {
- while(!jobManager.isPreparingForShutDown()){
- try{
+ while (!jobManager.isPreparingForShutDown()) {
+ try {
executorService.submit(singleRegistration).get();
//registration successful
return;
- }
- catch (Exception e){
+ } catch (Exception e) {
logger.warn("Unable to execute self registration process", e);
}
systemFunctions().sleep(5000);
@@ -117,7 +112,7 @@ public class NokiaSvnfmApplication {
private final JobManager jobManager;
@Autowired
- SelfDeRegistrationTrigger(SelfRegistrationManager selfRegistrationManager, JobManager jobManager){
+ SelfDeRegistrationTrigger(SelfRegistrationManager selfRegistrationManager, JobManager jobManager) {
this.jobManager = jobManager;
this.selfRegistrationManager = selfRegistrationManager;
}