Updated Branches: refs/heads/master 9a6dd1715 -> e03ac9844
fixing a NPE Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/e03ac984 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/e03ac984 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/e03ac984 Branch: refs/heads/master Commit: e03ac984403d2db2c871d6e17a54524ea1d95dd2 Parents: 9a6dd17 Author: Isuru <[email protected]> Authored: Fri Jan 10 12:07:25 2014 +0530 Committer: Isuru <[email protected]> Committed: Fri Jan 10 12:07:25 2014 +0530 ---------------------------------------------------------------------- .../stratos/manager/listener/InstanceStatusListener.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/e03ac984/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/listener/InstanceStatusListener.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/listener/InstanceStatusListener.java b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/listener/InstanceStatusListener.java index b3483ab..e371854 100644 --- a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/listener/InstanceStatusListener.java +++ b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/listener/InstanceStatusListener.java @@ -72,6 +72,13 @@ public class InstanceStatusListener implements MessageListener { }*/ //////////////////////////////////////////////////////////////////////////////////////////////////////////////// Set<CartridgeSubscription> cartridgeSubscriptions = new DataInsertionAndRetrievalManager().getCartridgeSubscription(clusterId); + if (cartridgeSubscriptions == null || cartridgeSubscriptions.isEmpty()) { + // No subscriptions, return + if (log.isDebugEnabled()) { + log.debug("No subscription information found for cluster id " + clusterId); + } + return; + } for (CartridgeSubscription cartridgeSubscription : cartridgeSubscriptions) { // If only this is a non-multitenant Cartridge Subscription and repository is not null, need to
