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; + } } _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
