Repository: stratos Updated Branches: refs/heads/master e6d98dea5 -> 8def69fc1
fixing an issue in mock instance termination Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/8def69fc Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/8def69fc Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/8def69fc Branch: refs/heads/master Commit: 8def69fc17125fd6b854a6f114672b8f5f427929 Parents: e6d98de Author: R-Rajkumar <[email protected]> Authored: Sun Mar 8 19:54:02 2015 +0530 Committer: R-Rajkumar <[email protected]> Committed: Sun Mar 8 19:54:02 2015 +0530 ---------------------------------------------------------------------- .../stratos/mock/iaas/services/impl/MockInstance.java | 11 +++++++++++ 1 file changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/8def69fc/components/org.apache.stratos.mock.iaas/src/main/java/org/apache/stratos/mock/iaas/services/impl/MockInstance.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.mock.iaas/src/main/java/org/apache/stratos/mock/iaas/services/impl/MockInstance.java b/components/org.apache.stratos.mock.iaas/src/main/java/org/apache/stratos/mock/iaas/services/impl/MockInstance.java index ab3d319..fda1bf0 100644 --- a/components/org.apache.stratos.mock.iaas/src/main/java/org/apache/stratos/mock/iaas/services/impl/MockInstance.java +++ b/components/org.apache.stratos.mock.iaas/src/main/java/org/apache/stratos/mock/iaas/services/impl/MockInstance.java @@ -74,6 +74,9 @@ public class MockInstance implements Runnable, Serializable { while (!terminated) { sleep(1000); } + + stopInstanceNotifierReceiver(); + stopHealthStatisticsPublisher(); if (log.isInfoEnabled()) { log.info(String.format("Mock member terminated: [member-id] %s", mockMemberContext.getMemberId())); @@ -139,6 +142,14 @@ public class MockInstance implements Runnable, Serializable { } } + private void stopHealthStatisticsPublisher() { + healthStatNotifierExecutorService.shutdownNow(); + } + + private void stopInstanceNotifierReceiver() { + eventListenerExecutorService.shutdownNow(); + } + private void sleep(long time) { try { Thread.sleep(time);
