Author: ruwan Date: Wed Jun 24 18:40:44 2009 New Revision: 39839 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=39839
Log: Fixing an issue in the subscriptions retrieval Modified: branches/synapse/1.3-wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java Modified: branches/synapse/1.3-wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.3-wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java?rev=39839&r1=39838&r2=39839&view=diff ============================================================================== --- branches/synapse/1.3-wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java (original) +++ branches/synapse/1.3-wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java Wed Jun 24 18:40:44 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; _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
