svn commit: r788237 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java

[ruwan]

Author: ruwan
Date: Thu Jun 25 01:41:53 2009
New Revision: 788237

URL: http://svn.apache.org/viewvc?rev=788237&view=rev
Log:
Fixing an issue in the subscriptions retrieval

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java?rev=788237&r1=788236&r2=788237&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
 Thu Jun 25 01:41:53 2009
@@ -30,6 +30,7 @@
 import org.wso2.eventing.Event;
 import org.wso2.eventing.Subscription;
 import org.wso2.eventing.SubscriptionManager;
+import org.wso2.eventing.SubscriptionData;
 import org.wso2.eventing.exceptions.EventException;
 
 import java.util.*;
@@ -50,10 +51,11 @@
 
     public List<Subscription> getStaticSubscriptions() {
         LinkedList<Subscription> list = new LinkedList<Subscription>();
-        for (Map.Entry<String, Subscription> stringSubscriptionEntry : 
store.entrySet()) {
-            if 
((stringSubscriptionEntry.getValue().getSubscriptionData().getProperty(
-                    SynapseEventingConstants.STATIC_ENTRY)).equals("true")) {
-                list.add(stringSubscriptionEntry.getValue());
+        for (Subscription stringSubscription : store.values()) {
+            SubscriptionData data = stringSubscription.getSubscriptionData();
+            if (data != null && "true".equals(data.getProperty(
+                    SynapseEventingConstants.STATIC_ENTRY))) {
+                list.add(stringSubscription);
             }
         }
         return list;