Author: asankaa Date: Fri Nov 21 05:07:53 2008 New Revision: 24526 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=24526
Log: Set oneway message for events 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=24526&r1=24525&r2=24526&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:07:53 2008 @@ -70,6 +70,7 @@ } else { List<Subscription> subscribers = eventSource.getSubscriptionManager().getMatchingSubscribers(smc); for (Subscription subscription : subscribers) { + smc.setProperty("OUT_ONLY","true"); // Set one way message for events subscription.getEndpoint().send(MessageHelper.cloneMessageContext(smc)); } } _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
