Author: fhanik Date: Mon May 14 05:25:21 2007 New Revision: 537797 URL: http://svn.apache.org/viewvc?view=rev&rev=537797 Log: Make sure to respect the option flag, otherwise you must order everything
Modified: tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java Modified: tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java URL: http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java?view=diff&rev=537797&r1=537796&r2=537797 ============================================================================== --- tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java (original) +++ tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java Mon May 14 05:25:21 2007 @@ -60,6 +60,10 @@ private int maxQueue = Integer.MAX_VALUE; public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException { + if ( !okToProcess(msg.getOptions()) ) { + super.sendMessage(destination, msg, payload); + return; + } for ( int i=0; i<destination.length; i++ ) { int nr = incCounter(destination[i]); //reduce byte copy @@ -73,6 +77,10 @@ } public void messageReceived(ChannelMessage msg) { + if ( !okToProcess(msg.getOptions()) ) { + super.messageReceived(msg); + return; + } int msgnr = XByteBuffer.toInt(msg.getMessage().getBytesDirect(),msg.getMessage().getLength()-4); msg.getMessage().trim(4); MessageOrder order = new MessageOrder(msgnr,(ChannelMessage)msg.deepclone()); --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]