[esb-java-dev] svn commit r24526 - 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: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));
             }
         }