You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by im...@apache.org on 2014/10/30 05:13:31 UTC
[07/50] [abbrv] git commit: fixing a issue in acquiring locks in
ApplicationTerminatedMessageProcessor
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/docker-grouping-merge
Commit: bea691b0fca8ac36b9d329d0b2a9da8369652d0f
Parents: b56e328
Author: Isuru Haththotuwa <is...@apache.org>
Authored: Mon Oct 27 13:18:18 2014 +0530
Committer: Isuru Haththotuwa <is...@apache.org>
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());