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

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-10-23 12:42:04 -0400 (Fri, 23 Oct 2009)
New Revision: 994

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java
Log:
Use OOB if sync repl

Modified: trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java	2009-10-23 16:41:35 UTC (rev 993)
+++ trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java	2009-10-23 16:42:04 UTC (rev 994)
@@ -349,6 +349,7 @@
       // if there is a FLUSH in progress, block till it completes
       flushTracker.blockUntilReleased(distributedSyncTimeout, MILLISECONDS);
       boolean asyncMarshalling = mode == ResponseMode.ASYNCHRONOUS;
+      if (!usePriorityQueue && ResponseMode.SYNCHRONOUS == mode) usePriorityQueue = true;
       try {
          RspList rsps = dispatcher.invokeRemoteCommands(toJGroupsAddressVector(recipients), rpcCommand, toJGroupsMode(mode),
                                                         timeout, false, usePriorityQueue,