Repository: stratos Updated Branches: refs/heads/master d26e6c8fc -> 1480813ea
Updating info logs in mock member Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/1480813e Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/1480813e Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/1480813e Branch: refs/heads/master Commit: 1480813eaf13902a6475e5c3b0faa6592c296621 Parents: d26e6c8 Author: Imesh Gunaratne <[email protected]> Authored: Mon Dec 8 16:51:34 2014 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Mon Dec 8 16:51:47 2014 +0530 ---------------------------------------------------------------------- .../stratos/cloud/controller/iaases/mock/MockMember.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/1480813e/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/mock/MockMember.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/mock/MockMember.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/mock/MockMember.java index ddce529..eb0f3c8 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/mock/MockMember.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/iaases/mock/MockMember.java @@ -26,7 +26,6 @@ import org.apache.stratos.cloud.controller.iaases.mock.statistics.MockHealthStat import java.io.Serializable; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; /** @@ -36,6 +35,7 @@ public class MockMember implements Runnable, Serializable { private static final Log log = LogFactory.getLog(MockMember.class); private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); + private static final int HEALTH_STAT_INTERVAL = 15; private MockMemberContext mockMemberContext; private boolean terminated; @@ -54,15 +54,14 @@ public class MockMember implements Runnable, Serializable { sleep(5000); MockMemberEventPublisher.publishInstanceActivatedEvent(mockMemberContext); - if (log.isInfoEnabled()) { - log.info("Starting health statistics notifier"); + log.info(String.format("Starting health statistics notifier: [member-id] %s", mockMemberContext.getMemberId())); } - final ScheduledFuture<?> scheduledFuture = scheduler.scheduleAtFixedRate( - new MockHealthStatisticsNotifier(mockMemberContext), 15, 15, TimeUnit.SECONDS); + scheduler.scheduleAtFixedRate(new MockHealthStatisticsNotifier(mockMemberContext), + HEALTH_STAT_INTERVAL, HEALTH_STAT_INTERVAL, TimeUnit.SECONDS); if (log.isInfoEnabled()) { - log.info("Health statistics notifier started"); + log.info(String.format("Health statistics notifier started: [member-id] %s", mockMemberContext.getMemberId())); } while(!terminated) {
