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

[indika]

Author: indika
Date: Thu Jan 21 05:20:11 2010
New Revision: 901532

URL: http://svn.apache.org/viewvc?rev=901532&view=rev
Log:
fix a compilation error due to eventting API change

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=901532&r1=901531&r2=901532&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 Jan 21 05:20:11 2010
@@ -27,10 +27,7 @@
 import org.apache.synapse.eventing.filters.TopicBasedEventFilter;
 import org.apache.synapse.util.xpath.SynapseXPath;
 import org.jaxen.JaxenException;
-import org.wso2.eventing.Event;
-import org.wso2.eventing.Subscription;
-import org.wso2.eventing.SubscriptionManager;
-import org.wso2.eventing.SubscriptionData;
+import org.wso2.eventing.*;
 import org.wso2.eventing.exceptions.EventException;
 
 import java.util.*;
@@ -68,6 +65,12 @@
 
     }
 
+    public String subscribeNonPersistantly(Subscription subscription,
+                                           EventDispatcher<MessageContext> 
dispatcher) throws EventException {
+        subscription.setEventDispatcher(dispatcher);
+        return subscribe(subscription);
+    }
+
     public boolean unsubscribe(String id) throws EventException {
         if (store.containsKey(id)) {
             store.remove(id);