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

[asankaa at wso2.com]

Author: asankaa
Date: Fri Nov 21 05:42:21 2008
New Revision: 24531
URL: http://wso2.org/svn/browse/wso2?view=rev&revision=24531

Log:
WS-E responce 


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

Modified: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java
URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java?rev=24531&r1=24530&r2=24531&view=diff
==============================================================================
--- branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java	(original)
+++ branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java	Fri Nov 21 05:42:21 2008
@@ -67,7 +67,14 @@
             rmc.setTo(new EndpointReference(replyAddress));
             rmc.setEnvelope(soapEnvelope);
             endpoint.send(MessageHelper.cloneMessageContext(rmc));
+        }else if (EventingConstants.WSE_UNSUBSCRIBE.equals(mc.getWSAAction())) {
+            // Unsubscribe for responce
+        }else if (EventingConstants.WSE_GET_STATUS.equals(mc.getWSAAction())) {
+            // Get responce status
+        }else if (EventingConstants.WSE_RENEW.equals(mc.getWSAAction())) {
+            // Renew subscription
         } else {
+            // Treat as an Event
             List<Subscription> subscribers = eventSource.getSubscriptionManager().getMatchingSubscribers(smc);
             for (Subscription subscription : subscribers) {
                 smc.setProperty("OUT_ONLY","true");    // Set one way message for events