You are viewing a plain text version of this content. The canonical link for it is here.

Posted to java-dev@axis.apache.org by az...@apache.org on 2008/06/23 17:04:02 UTC

svn commit: r670646 - /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java

Author: azeez
Date: Mon Jun 23 08:04:02 2008
New Revision: 670646

URL: http://svn.apache.org/viewvc?rev=670646&view=rev
Log:
Setting the at-most once option

Modified:
    webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java

Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java?rev=670646&r1=670645&r2=670646&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java Mon Jun 23 08:04:02 2008
@@ -645,6 +645,7 @@
 
         // Add a AtMostOnceInterceptor to support at-most-once message processing semantics
         AtMostOnceInterceptor atMostOnceInterceptor = new AtMostOnceInterceptor();
+        atMostOnceInterceptor.setOptionFlag(TribesConstants.AT_MOST_ONCE_OPTION);
         channel.addInterceptor(atMostOnceInterceptor);
 
         // Add the OrderInterceptor to preserve sender ordering