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]
