[infinispan-commits] Infinispan SVN: r1325 - trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-12-23 20:19:19 -0500 (Wed, 23 Dec 2009)
New Revision: 1325

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
Log:
[ISPN-320] (When using a RspFilter, JGroups GroupRequest mode should always be GET_FIRST)

Modified: trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2009-12-24 01:05:05 UTC (rev 1324)
+++ trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2009-12-24 01:19:19 UTC (rev 1325)
@@ -49,9 +49,10 @@
 import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
-import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import java.util.concurrent.atomic.AtomicBoolean;
 
+import static java.util.concurrent.TimeUnit.MILLISECONDS;
+
 /**
  * A JGroups RPC dispatcher that knows how to deal with {@link ReplicableCommand}s.
  *
@@ -235,7 +236,9 @@
          if (mode != GroupRequest.GET_NONE) {
             msg.setFlag(Message.DONT_BUNDLE);
          }
-         
+
+         if (filter != null) mode = GroupRequest.GET_FIRST;
+
          RspList retval = castMessage(dests, msg, mode, timeout, anycasting, filter);
          if (trace) log.trace("responses: {0}", retval);