diff options
Diffstat (limited to 'participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/StarterService.java')
-rw-r--r-- | participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/StarterService.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/StarterService.java b/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/StarterService.java index 589397db7..479fa44b6 100644 --- a/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/StarterService.java +++ b/participant/participant-impl/participant-impl-acelement/src/main/java/org/onap/policy/clamp/acm/element/service/StarterService.java @@ -75,12 +75,12 @@ public class StarterService extends AbstractElementService implements AutoClosea if (timerPool != null) { throw new PfModelRuntimeException(Response.Status.CONFLICT, "StarterService alredy actived!"); } - receiver = elementConfig.getElementId(); + receiver = elementConfig.getReceiverId(); timerPool = new ScheduledThreadPoolExecutor(1); timerPool.setRemoveOnCancelPolicy(true); - future = timerPool.scheduleAtFixedRate(this::sendMessage, elementConfig.getTimerSec(), - elementConfig.getTimerSec(), TimeUnit.MILLISECONDS); + future = timerPool.scheduleAtFixedRate(this::sendMessage, elementConfig.getTimerMs(), + elementConfig.getTimerMs(), TimeUnit.MILLISECONDS); } private void sendMessage() { @@ -99,8 +99,8 @@ public class StarterService extends AbstractElementService implements AutoClosea if (future != null) { future.cancel(true); } - future = timerPool.scheduleAtFixedRate(this::sendMessage, elementConfig.getTimerSec(), - elementConfig.getTimerSec(), TimeUnit.MILLISECONDS); + future = timerPool.scheduleAtFixedRate(this::sendMessage, elementConfig.getTimerMs(), + elementConfig.getTimerMs(), TimeUnit.MILLISECONDS); } @Override |