Author: fhanik Date: Thu May 15 09:59:31 2008 New Revision: 656735 URL: http://svn.apache.org/viewvc?rev=656735&view=rev Log: expose alwaysSend flag for message dispatch interceptor
Modified: tomcat/tc6.0.x/trunk/STATUS.txt tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java tomcat/tc6.0.x/trunk/webapps/docs/changelog.xml tomcat/tc6.0.x/trunk/webapps/docs/config/cluster-interceptor.xml Modified: tomcat/tc6.0.x/trunk/STATUS.txt URL: http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/STATUS.txt?rev=656735&r1=656734&r2=656735&view=diff ============================================================================== --- tomcat/tc6.0.x/trunk/STATUS.txt (original) +++ tomcat/tc6.0.x/trunk/STATUS.txt Thu May 15 09:59:31 2008 @@ -61,11 +61,6 @@ +1: jfclere, rjung, fhanik, remm, pero -1: -* Expose always send flag for configuration - http://svn.apache.org/viewvc?view=rev&revision=649252 - +1: fhanik, markt, pero - -1: - * Fix https://issues.apache.org/bugzilla/show_bug.cgi?id=43343 Correctly handle requesting a session we are in the middle of persisting Modified: tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java URL: http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java?rev=656735&r1=656734&r2=656735&view=diff ============================================================================== --- tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java (original) +++ tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java Thu May 15 09:59:31 2008 @@ -198,5 +198,13 @@ return link; } + public boolean isAlwaysSend() { + return alwaysSend; + } + + public void setAlwaysSend(boolean alwaysSend) { + this.alwaysSend = alwaysSend; + } + } Modified: tomcat/tc6.0.x/trunk/webapps/docs/changelog.xml URL: http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/webapps/docs/changelog.xml?rev=656735&r1=656734&r2=656735&view=diff ============================================================================== --- tomcat/tc6.0.x/trunk/webapps/docs/changelog.xml (original) +++ tomcat/tc6.0.x/trunk/webapps/docs/changelog.xml Thu May 15 09:59:31 2008 @@ -35,6 +35,7 @@ <section name="Tomcat 6.0.17 (remm)"> <subsection name="Catalina"> <changelog> + <update>expose alwaysSend flag for message dispatch interceptor</update> <fix><bug>44833</bug> correctly override StandardSession methods from DeltaSession </fix> Modified: tomcat/tc6.0.x/trunk/webapps/docs/config/cluster-interceptor.xml URL: http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/webapps/docs/config/cluster-interceptor.xml?rev=656735&r1=656734&r2=656735&view=diff ============================================================================== --- tomcat/tc6.0.x/trunk/webapps/docs/config/cluster-interceptor.xml (original) +++ tomcat/tc6.0.x/trunk/webapps/docs/config/cluster-interceptor.xml Thu May 15 09:59:31 2008 @@ -112,6 +112,15 @@ The default and hard coded value is <code>8 (org.apache.catalina.tribes.Channel.SEND_OPTIONS_ASYNCHRONOUS)</code>. The dispatcher will trigger on this value only, as it is predefined by Tribes. </attribute> + <attribute name="alwaysSend" required="false"> + What behavior should be executed when the dispatch queue is full. If <code>true</code> (default), then the message is + is sent synchronously, if <code>false</code> an error is thrown. + </attribute> + <attribute name="maxQueueSize" required="false"> + Size in bytes of the dispatch queue, the default value is <code> 1024*1024*64 (64MB)</code> sets the maximum queue size for the dispatch queue + if the queue fills up, one can trigger the behavior, if <code>alwaysSend</code> is set to true, the mesage will be sent synchronously + if the flag is false, an error is thrown + </attribute> </attributes> </subsection> <subsection name="org.apache.catalina.tribes.group.interceptors.TcpFailureDetector Attributes"> --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]