[esb-java-dev] svn commit r24627 - branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders

[asankaa at wso2.com]

Author: asankaa
Date: Sun Nov 23 09:46:22 2008
New Revision: 24627
URL: http://wso2.org/svn/browse/wso2?view=rev&revision=24627

Log:
change HCV to constents introduce unsubscription 


Modified:
   branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java

Modified: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java
URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java?rev=24627&r1=24626&r2=24627&view=diff
==============================================================================
--- branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java	(original)
+++ branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java	Sun Nov 23 09:46:22 2008
@@ -44,13 +44,13 @@
 
     private static final Log log = LogFactory.getLog(SubscriptionMessageBuilder.class);
 
-    private static final QName SUBSCRIBE_QNAME  = new QName(EventingConstants.WSE_EVENTING_NS, "Subscribe");
-    private static final QName DELIVERY_QNAME   = new QName(EventingConstants.WSE_EVENTING_NS, "Delivery");
-    private static final QName FILTER_QNAME     = new QName(EventingConstants.WSE_EVENTING_NS, "Filter");
-    private static final QName NOTIFY_TO_QNAME  = new QName(EventingConstants.WSE_EVENTING_NS, "NotifyTo");
-    private static final QName ATT_DIALECT      = new QName(XMLConfigConstants.NULL_NAMESPACE, "Dialect");
-    private static final QName ATT_XPATH        = new QName(XMLConfigConstants.NULL_NAMESPACE, "XPath");
-
+    private static final QName SUBSCRIBE_QNAME  = new QName(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EN_SUBSCRIBE);
+    private static final QName DELIVERY_QNAME   = new QName(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EN_DELIVERY);
+    private static final QName FILTER_QNAME     = new QName(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EN_FILTER);
+    private static final QName NOTIFY_TO_QNAME  = new QName(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EN_NOTIFY_TO);
+    private static final QName ATT_DIALECT      = new QName(XMLConfigConstants.NULL_NAMESPACE, EventingConstants.WSE_EN_DIALECT);
+    private static final QName ATT_XPATH        = new QName(XMLConfigConstants.NULL_NAMESPACE, EventingConstants.WSE_EN_XPATH);
+    private static final QName IDENTIFIER       = new QName(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EN_IDENTIFIER);
     public static Subscription createSubscription(MessageContext mc) {
         Subscription subscription = null;
         OMElement elem = mc.getEnvelope().getBody().getFirstChildWithName(SUBSCRIBE_QNAME);
@@ -116,4 +116,14 @@
         log.error(message, e);
         throw new SynapseException(message, e);
     }
+
+    /**
+     * create request for unsubscribr request
+     * @param mc
+     * @return
+     */
+    public Subscription createUnSubscribeMessage(MessageContext mc){
+      Subscription subscription = new Subscription();
+      return subscription;
+    }
 }