Repository: stratos Updated Branches: refs/heads/4.0.0-grouping d11103577 -> 4e1ac4813
removing a thread join in AutoscalerTopologyEventReceiver#startApplicationMonitor() Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/4e1ac481 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/4e1ac481 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/4e1ac481 Branch: refs/heads/4.0.0-grouping Commit: 4e1ac4813039f353e3955443527926eaa17908f2 Parents: d111035 Author: Isuru Haththotuwa <[email protected]> Authored: Fri Oct 10 16:27:20 2014 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Fri Oct 10 16:27:20 2014 +0530 ---------------------------------------------------------------------- .../topology/AutoscalerTopologyEventReceiver.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/4e1ac481/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java index 91189fb..a7b6eda 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyEventReceiver.java @@ -584,19 +584,19 @@ public class AutoscalerTopologyEventReceiver implements Runnable { th = new Thread( new ApplicationMonitorAdder(application)); } - if (th != null) { + // if (th != null) { th.start(); - try { - th.join(); - } catch (InterruptedException ignore) { - } + // try { + // th.join(); + // } catch (InterruptedException ignore) { + // } if (log.isDebugEnabled()) { log.debug(String .format("Application monitor thread has been started successfully: " + "[application] %s ", application.getUniqueIdentifier())); } - } + // } } private class ApplicationMonitorAdder implements Runnable {
