You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ru...@apache.org on 2009/06/25 03:41:53 UTC
svn commit: r788237 -
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
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;