Updated Branches: refs/heads/master 779f0cbb2 -> 26be402c7
Improving synchronization of stat queues Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/7933ea28 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/7933ea28 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/7933ea28 Branch: refs/heads/master Commit: 7933ea2899b96c9c8ca2dd817541a950b4aa9a79 Parents: 22ff440 Author: Lahiru Sandaruwan <[email protected]> Authored: Tue Jan 14 22:57:35 2014 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Tue Jan 14 22:57:35 2014 +0530 ---------------------------------------------------------------------- .../message/receiver/health/stat/HealthStatEventMessageQueue.java | 2 +- .../instance/notifier/InstanceNotifierEventMessageQueue.java | 2 +- .../messaging/message/receiver/tenant/TenantEventMessageQueue.java | 2 +- .../message/receiver/topology/TopologyEventMessageQueue.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/7933ea28/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventMessageQueue.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventMessageQueue.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventMessageQueue.java index d68e98e..d264121 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventMessageQueue.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventMessageQueue.java @@ -13,7 +13,7 @@ public class HealthStatEventMessageQueue extends LinkedBlockingQueue<TextMessage private HealthStatEventMessageQueue(){ } - public static synchronized HealthStatEventMessageQueue getInstance() { + public static HealthStatEventMessageQueue getInstance() { if (instance == null) { synchronized (HealthStatEventMessageQueue.class){ if (instance == null) { http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/7933ea28/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageQueue.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageQueue.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageQueue.java index f345ed2..1a49fac 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageQueue.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageQueue.java @@ -31,7 +31,7 @@ public class InstanceNotifierEventMessageQueue extends LinkedBlockingQueue<TextM private InstanceNotifierEventMessageQueue(){ } - public static synchronized InstanceNotifierEventMessageQueue getInstance() { + public static InstanceNotifierEventMessageQueue getInstance() { if (instance == null) { synchronized (InstanceNotifierEventMessageQueue.class){ if (instance == null) { http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/7933ea28/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantEventMessageQueue.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantEventMessageQueue.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantEventMessageQueue.java index ca2f7a6..423f169 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantEventMessageQueue.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantEventMessageQueue.java @@ -31,7 +31,7 @@ public class TenantEventMessageQueue extends LinkedBlockingQueue<TextMessage>{ private TenantEventMessageQueue(){ } - public static synchronized TenantEventMessageQueue getInstance() { + public static TenantEventMessageQueue getInstance() { if (instance == null) { synchronized (TenantEventMessageQueue.class){ if (instance == null) { http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/7933ea28/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageQueue.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageQueue.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageQueue.java index 8c6fbdb..db33289 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageQueue.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageQueue.java @@ -32,7 +32,7 @@ public class TopologyEventMessageQueue extends LinkedBlockingQueue<TextMessage>{ private TopologyEventMessageQueue(){ } - public static synchronized TopologyEventMessageQueue getInstance() { + public static TopologyEventMessageQueue getInstance() { if (instance == null) { synchronized (TopologyEventMessageQueue.class){ if (instance == null) {
