Repository: stratos Updated Branches: refs/heads/4.0.0-grouping b56e32852 -> bea691b0f
fixing a issue in acquiring locks in ApplicationTerminatedMessageProcessor Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/bea691b0 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/bea691b0 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/bea691b0 Branch: refs/heads/4.0.0-grouping Commit: bea691b0fca8ac36b9d329d0b2a9da8369652d0f Parents: b56e328 Author: Isuru Haththotuwa <[email protected]> Authored: Mon Oct 27 13:18:18 2014 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Mon Oct 27 13:18:18 2014 +0530 ---------------------------------------------------------------------- .../topology/ApplicationTerminatedMessageProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/bea691b0/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationTerminatedMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationTerminatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationTerminatedMessageProcessor.java index 49a8d22..3b91e3f 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationTerminatedMessageProcessor.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationTerminatedMessageProcessor.java @@ -58,7 +58,7 @@ public class ApplicationTerminatedMessageProcessor extends MessageProcessor { ApplicationTerminatedEvent event = (ApplicationTerminatedEvent) Util. jsonToObject(message, ApplicationTerminatedEvent.class); - TopologyUpdater.acquireWriteLockForApplication(event.getAppId()); + TopologyUpdater.acquireWriteLockForApplications(); Set<ClusterDataHolder> clusterDataHolders = event.getClusterData(); if (clusterDataHolders != null) { for (ClusterDataHolder clusterData : clusterDataHolders) { @@ -70,7 +70,7 @@ public class ApplicationTerminatedMessageProcessor extends MessageProcessor { return doProcess(event, topology); } finally { - TopologyUpdater.releaseWriteLockForApplication(event.getAppId()); + TopologyUpdater.releaseWriteLockForApplications(); if (clusterDataHolders != null) { for (ClusterDataHolder clusterData : clusterDataHolders) { TopologyUpdater.releaseWriteLockForService(clusterData.getServiceType());
