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