commenting unused methods after making EventReceivers singleton
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/6b179e9c Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/6b179e9c Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/6b179e9c Branch: refs/heads/stratos-4.1.x Commit: 6b179e9c5494051c0901873caa9d977646fd93a1 Parents: 334bb02 Author: Isuru Haththotuwa <[email protected]> Authored: Thu Dec 17 16:04:54 2015 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Fri Dec 25 15:49:01 2015 +0530 ---------------------------------------------------------------------- .../StratosManagerServiceComponent.java | 25 -------------------- .../topology/TopologyEventReceiver.java | 8 ------- 2 files changed, 33 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/6b179e9c/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/internal/StratosManagerServiceComponent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/internal/StratosManagerServiceComponent.java b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/internal/StratosManagerServiceComponent.java index ddd2288..0dbc417 100644 --- a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/internal/StratosManagerServiceComponent.java +++ b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/internal/StratosManagerServiceComponent.java @@ -327,30 +327,5 @@ public class StratosManagerServiceComponent { // Close event publisher connections to message broker EventPublisherPool.close(MessagingUtil.Topics.INSTANCE_NOTIFIER_TOPIC.getTopicName()); EventPublisherPool.close(MessagingUtil.Topics.TENANT_TOPIC.getTopicName()); - - shutdownExecutorService(THREAD_POOL_ID); - shutdownScheduledExecutorService(SCHEDULER_THREAD_POOL_ID); - } - - private void shutdownExecutorService(String executorServiceId) { - ExecutorService executorService = StratosThreadPool.getExecutorService(executorServiceId, 1); - if (executorService != null) { - shutdownExecutorService(executorService); - } - } - - private void shutdownScheduledExecutorService(String executorServiceId) { - ExecutorService executorService = StratosThreadPool.getScheduledExecutorService(executorServiceId, 1); - if (executorService != null) { - shutdownExecutorService(executorService); - } - } - - private void shutdownExecutorService(ExecutorService executorService) { - try { - executorService.shutdownNow(); - } catch (Exception e) { - log.warn("An error occurred while shutting down executor service", e); - } } } http://git-wip-us.apache.org/repos/asf/stratos/blob/6b179e9c/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventReceiver.java index 648a8fb..64af927 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventReceiver.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventReceiver.java @@ -115,12 +115,4 @@ public class TopologyEventReceiver extends StratosEventReceiver { } }); } - -// public ExecutorService getExecutorService() { -// return executor; -// } -// -// public void setExecutorService(ExecutorService executor) { -// this.executor = executor; -// } }
