svn commit: r762003 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: config/xml/eventing/ eventing/ eventing/managers/

[as...@apache.org]

Author: asanka
Date: Sat Apr  4 20:45:33 2009
New Revision: 762003

URL: http://svn.apache.org/viewvc?rev=762003&view=rev
Log:
Change the getStaticSubscriptions, adding doc comments.

Modified:
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/eventing/EventSourceSerializer.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java
    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/config/xml/eventing/EventSourceSerializer.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/eventing/EventSourceSerializer.java?rev=762003&r1=762002&r2=762003&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/eventing/EventSourceSerializer.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/eventing/EventSourceSerializer.java Sat Apr  4 20:45:33 2009
@@ -26,8 +26,6 @@
 import org.apache.axis2.databinding.utils.ConverterUtil;
 import org.apache.synapse.config.xml.XMLConfigConstants;
 import org.apache.synapse.eventing.SynapseEventSource;
-import org.apache.synapse.eventing.SynapseEventingConstants;
-import org.apache.synapse.eventing.SynapseSubscription;
 import org.wso2.eventing.Subscription;
 
 import java.util.Iterator;
@@ -76,7 +74,7 @@
             evenSourceElem.addChild(subManagerElem);
             // Adding static subscriptions
             List<Subscription> staticSubscriptionList =
-                    eventSource.getSubscriptionManager().getStaticSubscribers();
+                    eventSource.getSubscriptionManager().getStaticSubscriptions();
             for (Iterator<Subscription> iterator = staticSubscriptionList.iterator();
                  iterator.hasNext();) {
                 Subscription staticSubscription = iterator.next();

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java?rev=762003&r1=762002&r2=762003&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java Sat Apr  4 20:45:33 2009
@@ -52,6 +52,12 @@
 
 /**
  * Eventsource that accepts the event requests using a message reciver.
+ * Eventsource is responsible on two tasks accepting the subscriptions and subscription related
+ * reqests and dispatching events.
+ * Subscriptions conatines operations listed in the WS-Eventing specification. {SubscribeOP,
+ * UnsubscribeOP, RenewOP, GetstatusOP, SubscriptionEndOP}
+ * based on the action in the request eventsource identify the operation and send it for processing.
+ * Eventsource link with a suscription manager to store the subscriptions. 
  */
 public class SynapseEventSource extends SynapseMessageReceiver {
 

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java?rev=762003&r1=762002&r2=762003&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java Sat Apr  4 20:45:33 2009
@@ -26,7 +26,9 @@
 import org.wso2.eventing.SubscriptionData;
 
 /**
- * Bean that keep subscription and subscription metadata.
+ * Bean that keep subscription and subscription metadata. Addition to the subscription in the core
+ * API SynapseSubscription add the UUID as the subscription ID, add a new constructor to define the
+ * delivery mode. 
  */
 public class SynapseSubscription extends Subscription {
 

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java?rev=762003&r1=762002&r2=762003&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java Sat Apr  4 20:45:33 2009
@@ -29,7 +29,9 @@
 import java.util.Map;
 
 /**
- * Subscription Manager for Synapse
+ * Subscription Manager for Synapse, addition to the core subscription manager in the API synapse
+ * adds the getStaticSubscriptions method. Static subscriptions are the subscriptions that can confi
+ * -gure in the Synapse configuration and loded in the startup.   
  */
 public abstract class SynapseSubscriptionManager implements SubscriptionManager<MessageContext> {
 
@@ -40,7 +42,7 @@
      *
      * @return List of static subscriptions
      */
-    public abstract List<Subscription> getStaticSubscribers();
+    public abstract List<Subscription> getStaticSubscriptions();
 
 
     public void addProperty(String name, String value) {

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=762003&r1=762002&r2=762003&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 Sat Apr  4 20:45:33 2009
@@ -53,7 +53,7 @@
     private SynapseXPath topicXPath;
     private static final Log log = LogFactory.getLog(DefaultInMemorySubscriptionManager.class);
 
-    public List<Subscription> getStaticSubscribers() {
+    public List<Subscription> getStaticSubscriptions() {
         LinkedList<Subscription> list = new LinkedList<Subscription>();
         for (Map.Entry<String, Subscription> stringSubscriptionEntry : store.entrySet()) {
             if ((stringSubscriptionEntry.getValue().getSubscriptionData().getProperty(